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

Class EventPublisher

java.lang.Object

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

All Implemented Interfaces:

Flow.Publisher<Map<String,Object>>

public class EventPublisher
extends Object
implements Flow.Publisher<Map<String,Object>>

Jsonrpc implementation of Flow.Publisher

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	EventPublisher.EventCallable	Event processing task which is submit to a ExecutorService for processing.

Field Summary

Fields

Modifier and Type	Field	Description
private final EventDecomposer	decomposer
private final int	eventTimeoutInHours
private final ExecutorService	executorService
private static final org.slf4j.Logger	log
private final SubscriptionMatcher	matcher
private final ScheduledExecutorService	scheduledExecutorService

Constructor Summary

Constructors

Constructor	Description
EventPublisher(ExecutorService executorService, int eventTimeoutInHours)

Method Summary

Modifier and Type	Method	Description
private void	clean(SubscriptionHolder holder)
void	cleanupOldEvents()
void	close()
int	countEvents(JsonRpcEvent event)
private void	process(SubscriptionHolder holder)
void	process(JsonRpcEvent event)	This method is used by @link ResponseWorker to submit an @link JsonRpcEvent for processing.
void	publish(String subscriptionId, Map<String,Object> params)
private void	scheduleCleanupTask()
void	subscribe(Flow.Subscriber<? super Map<String,Object>> subscriber)

Methods inherited from class java.lang.Object

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

Field Details

log

private static final org.slf4j.Logger log

executorService

private final ExecutorService executorService

scheduledExecutorService

private final ScheduledExecutorService scheduledExecutorService

matcher

private final SubscriptionMatcher matcher

decomposer

private final EventDecomposer decomposer

eventTimeoutInHours

private final int eventTimeoutInHours

Constructor Details

EventPublisher

public EventPublisher(ExecutorService executorService,
 int eventTimeoutInHours)

Method Details

scheduleCleanupTask

private void scheduleCleanupTask()

cleanupOldEvents

public void cleanupOldEvents()

subscribe

public void subscribe(Flow.Subscriber<? super Map<String,Object>> subscriber)

Specified by:

subscribe in interface Flow.Publisher<Map<String,Object>>

publish

public void publish(String subscriptionId,
 Map<String,Object> params)
             throws IOException

Throws:

IOException

process

private void process(SubscriptionHolder holder)

clean

private void clean(SubscriptionHolder holder)

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()