Class EventSubscriber
- java.lang.Object
-
- org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
-
- All Implemented Interfaces:
Subscriber<java.util.Map<java.lang.String,java.lang.Object>>
public abstract class EventSubscriber extends java.lang.Object implements Subscriber<java.util.Map<java.lang.String,java.lang.Object>>
Subscription id contains <receiver>.<component>.<operation_id>.<unique_id>.
-
-
Field Summary
Fields Modifier and Type Field Description private java.lang.String
subscriptionId
-
Constructor Summary
Constructors Constructor Description EventSubscriber(java.lang.String subscriptionId)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description java.lang.String
getSubscriptionId()
abstract void
onComplete()
Successful terminal state.abstract void
onError(java.lang.Throwable t)
Failed terminal state.abstract void
onNext(java.util.Map<java.lang.String,java.lang.Object> t)
Data notification sent by thePublisher
in response to requests toSubscription.request(int)
.abstract void
onSubscribe(Subscription s)
Invoked after callingPublisher.subscribe(Subscriber)
.
-
-
-
Method Detail
-
onSubscribe
public abstract void onSubscribe(Subscription s)
Description copied from interface:Subscriber
Invoked after callingPublisher.subscribe(Subscriber)
.No data will start flowing until
Subscription.request(int)
is invoked.It is the responsibility of this
Subscriber
instance to callSubscription.request(int)
whenever more data is wanted.The
Publisher
will send notifications only in response toSubscription.request(int)
.- Specified by:
onSubscribe
in interfaceSubscriber<java.util.Map<java.lang.String,java.lang.Object>>
- Parameters:
s
-Subscription
that allows requesting data viaSubscription.request(int)
-
onNext
public abstract void onNext(java.util.Map<java.lang.String,java.lang.Object> t)
Description copied from interface:Subscriber
Data notification sent by thePublisher
in response to requests toSubscription.request(int)
.- Specified by:
onNext
in interfaceSubscriber<java.util.Map<java.lang.String,java.lang.Object>>
- Parameters:
t
- the element signaled
-
onError
public abstract void onError(java.lang.Throwable t)
Description copied from interface:Subscriber
Failed terminal state.It is up to implementer to decide whether to cancel subscription or use
Subscription.request(int)
and expect further notifications.- Specified by:
onError
in interfaceSubscriber<java.util.Map<java.lang.String,java.lang.Object>>
- Parameters:
t
- the throwable signaled
-
onComplete
public abstract void onComplete()
Description copied from interface:Subscriber
Successful terminal state.No further events will be sent even if
Subscription.request(int)
is invoked again.- Specified by:
onComplete
in interfaceSubscriber<java.util.Map<java.lang.String,java.lang.Object>>
-
getSubscriptionId
public java.lang.String getSubscriptionId()
- Returns:
- subscription id which is used to match incoming events.
-
-