Class EventSubscriber
- java.lang.Object
-
- org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber
-
- All Implemented Interfaces:
java.util.concurrent.Flow.Subscriber<java.util.Map<java.lang.String,java.lang.Object>>
public abstract class EventSubscriber extends java.lang.Object implements java.util.concurrent.Flow.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()
abstract void
onError(java.lang.Throwable t)
abstract void
onNext(java.util.Map<java.lang.String,java.lang.Object> t)
abstract void
onSubscribe(java.util.concurrent.Flow.Subscription s)
-
-
-
Method Detail
-
onSubscribe
public abstract void onSubscribe(java.util.concurrent.Flow.Subscription s)
- Specified by:
onSubscribe
in interfacejava.util.concurrent.Flow.Subscriber<java.util.Map<java.lang.String,java.lang.Object>>
-
onNext
public abstract void onNext(java.util.Map<java.lang.String,java.lang.Object> t)
- Specified by:
onNext
in interfacejava.util.concurrent.Flow.Subscriber<java.util.Map<java.lang.String,java.lang.Object>>
-
onError
public abstract void onError(java.lang.Throwable t)
- Specified by:
onError
in interfacejava.util.concurrent.Flow.Subscriber<java.util.Map<java.lang.String,java.lang.Object>>
-
onComplete
public abstract void onComplete()
- Specified by:
onComplete
in interfacejava.util.concurrent.Flow.Subscriber<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.
-
-