EventSubscriber

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.events.EventSubscriber

All Implemented Interfaces:: Flow.Subscriber<Map<String,Object>>

public abstract class EventSubscriber extends Object implements Flow.Subscriber<Map<String,Object>>

Subscription id contains <receiver>.<component>.<operation_id>.<unique_id>.

Field Summary

Fields

Modifier and Type

Field

Description

private String

subscriptionId
Constructor Summary

Constructors

Constructor

Description

EventSubscriber(String subscriptionId)
Method Summary

Modifier and Type

Method

Description

String

getSubscriptionId()

abstract void

onComplete()

abstract void

onError(Throwable t)

abstract void

onNext(Map<String,Object> t)

abstract void

onSubscribe(Flow.Subscription s)

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

Field Details
- subscriptionId
  
  private String subscriptionId
Constructor Details
- EventSubscriber
  
  public EventSubscriber(String subscriptionId)
  
  Parameters:
  
  subscriptionId - subscription id which is used to match an event to subscription.
Method Details
- onSubscribe
  
  public abstract void onSubscribe(Flow.Subscription s)
  
  Specified by:
  
  onSubscribe in interface Flow.Subscriber<Map<String,Object>>
- onNext
  
  public abstract void onNext(Map<String,Object> t)
  
  Specified by:
  
  onNext in interface Flow.Subscriber<Map<String,Object>>
- onError
  
  public abstract void onError(Throwable t)
  
  Specified by:
  
  onError in interface Flow.Subscriber<Map<String,Object>>
- onComplete
  
  public abstract void onComplete()
  
  Specified by:
  
  onComplete in interface Flow.Subscriber<Map<String,Object>>
- getSubscriptionId
  
  public String getSubscriptionId()
  
  Returns:
  
  subscription id which is used to match incoming events.