EventPublisher.EventCallable

java.lang.Object

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

All Implemented Interfaces:: Callable<Void>

Enclosing class:: EventPublisher

class EventPublisher.EventCallable extends Object implements Callable<Void>

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 SubscriptionHolder

holder
Constructor Summary

Constructors

Constructor

Description

EventCallable(SubscriptionHolder holder, EventDecomposer decomposer)
Method Summary

Modifier and Type

Method

Description

Void

call()

private void

handleEvent(Flow.Subscriber<Map<String,Object>> subscriber, JsonRpcEvent event)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- holder
  
  private final SubscriptionHolder holder
- decomposer
  
  private final EventDecomposer decomposer
Constructor Details
- EventCallable
  
  public EventCallable(SubscriptionHolder holder, EventDecomposer decomposer)
  
  Parameters:
  
  holder - Holds subscription information.
  
  decomposer - is used for decomposing event before notifying @link EventSubscriber.
Method Details
- call
  
  public Void call()
  
  Specified by:
  
  call in interface Callable<Void>
- handleEvent
  
  private void handleEvent(Flow.Subscriber<Map<String,Object>> subscriber, JsonRpcEvent event)