Class EventPublisher.EventCallable
- java.lang.Object
-
- org.ovirt.vdsm.jsonrpc.client.events.EventPublisher.EventCallable
-
- All Implemented Interfaces:
java.util.concurrent.Callable<java.lang.Void>
- Enclosing class:
- EventPublisher
class EventPublisher.EventCallable extends java.lang.Object implements java.util.concurrent.Callable<java.lang.Void>
Event processing task which is submit to aExecutorService
for processing.
-
-
Field Summary
Fields Modifier and Type Field Description private EventDecomposer
decomposer
private SubscriptionHolder
holder
-
Constructor Summary
Constructors Constructor Description EventCallable(SubscriptionHolder holder, EventDecomposer decomposer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Void
call()
private void
handleEvent(Subscriber<java.util.Map<java.lang.String,java.lang.Object>> subscriber, JsonRpcEvent event)
-
-
-
Field Detail
-
holder
private SubscriptionHolder holder
-
decomposer
private EventDecomposer decomposer
-
-
Constructor Detail
-
EventCallable
public EventCallable(SubscriptionHolder holder, EventDecomposer decomposer)
- Parameters:
holder
- Holds subscription information.decomposer
- is used for decomposing event before notifying @linkEventSubscriber
.
-
-
Method Detail
-
call
public java.lang.Void call() throws java.lang.Exception
- Specified by:
call
in interfacejava.util.concurrent.Callable<java.lang.Void>
- Throws:
java.lang.Exception
-
handleEvent
private void handleEvent(Subscriber<java.util.Map<java.lang.String,java.lang.Object>> subscriber, JsonRpcEvent event)
-
-