Package org.ovirt.vdsm.jsonrpc.client.events

Class EventPublisher

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.events.EventPublisher

All Implemented Interfaces:

Publisher<java.util.Map<java.lang.String,java.lang.Object>,EventSubscriber>

public class EventPublisher
extends java.lang.Object
implements Publisher<java.util.Map<java.lang.String,java.lang.Object>,EventSubscriber>

Jsonrpc implementation of Publisher

Constructor Summary

Constructors

Constructor	Description
EventPublisher(java.util.concurrent.ExecutorService executorService, int eventTimeoutInHours)

Method Summary

Modifier and Type	Method	Description
void	cleanupOldEvents()
void	close()
int	countEvents(JsonRpcEvent event)
void	process(JsonRpcEvent event)	This method is used by @link ResponseWorker to submit an @link JsonRpcEvent for processing.
void	publish(java.lang.String subscriptionId, java.util.Map<java.lang.String,java.lang.Object> params)	Request Publisher to send data.
void	subscribe(EventSubscriber subscriber)	Request Publisher to start streaming data.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventPublisher

public EventPublisher(java.util.concurrent.ExecutorService executorService,
                      int eventTimeoutInHours)

Method Detail

cleanupOldEvents

public void cleanupOldEvents()

subscribe

public void subscribe(EventSubscriber subscriber)

Description copied from interface: Publisher

Request Publisher to start streaming data.

This is a "factory method" and can be called multiple times, each time starting a new Subscription.

Each Subscription will work for only a single Subscriber.

A Subscriber should only subscribe once to a single Publisher.

If the Publisher rejects the subscription attempt or otherwise fails it will signal the error via Subscriber.onError(java.lang.Throwable).

Specified by:

subscribe in interface Publisher<java.util.Map<java.lang.String,java.lang.Object>,EventSubscriber>

Parameters:

subscriber - the Subscriber that will consume signals from this Publisher

publish

public void publish(java.lang.String subscriptionId,
                    java.util.Map<java.lang.String,java.lang.Object> params)
             throws java.io.IOException

Description copied from interface: Publisher

Request Publisher to send data.

Specified by:

publish in interface Publisher<java.util.Map<java.lang.String,java.lang.Object>,EventSubscriber>

Parameters:

subscriptionId - the identifier for Subscriber who will consume the event

params - the data that needs to be sent to the Subscriber

Throws:

java.io.IOException - an exception is thrown if the params cannot be serialized

process

public void process(JsonRpcEvent event)

This method is used by @link ResponseWorker to submit an @link JsonRpcEvent for processing.

Parameters:

event - which is submitted for processing.

countEvents

public int countEvents(JsonRpcEvent event)

close

public void close()