Package pubsub

Class Subscriber

java.lang.Object

pubsub.Subscriber

public class Subscriber
extends Object

Constructor Summary

Constructors

Constructor	Description
Subscriber(AsyncCuratorFramework client)

Method Summary

Modifier and Type	Method	Description
CachedModeledFramework<Instance>	startInstanceSubscriber(InstanceType instanceType)	Start a subscriber (a CachedModeledFramework instance) using the Instance client template
CachedModeledFramework<LocationAvailable>	startLocationAvailableSubscriber(Group group, Priority priority)	Start a subscriber (a CachedModeledFramework instance) using the LocationAvailable client template
CachedModeledFramework<UserCreated>	startUserCreatedSubscriber(Group group, Priority priority)	Start a subscriber (a CachedModeledFramework instance) using the UserCreated client template

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Subscriber

public Subscriber(AsyncCuratorFramework client)

Method Details

startLocationAvailableSubscriber

public CachedModeledFramework<LocationAvailable> startLocationAvailableSubscriber(Group group,
 Priority priority)

Start a subscriber (a CachedModeledFramework instance) using the LocationAvailable client template

Parameters:

group - group to listen for

priority - priority to listen for

Returns:

CachedModeledFramework instance (already started)

startUserCreatedSubscriber

public CachedModeledFramework<UserCreated> startUserCreatedSubscriber(Group group,
 Priority priority)

Start a subscriber (a CachedModeledFramework instance) using the UserCreated client template

Parameters:

group - group to listen for

priority - priority to listen for

Returns:

CachedModeledFramework instance (already started)

startInstanceSubscriber

public CachedModeledFramework<Instance> startInstanceSubscriber(InstanceType instanceType)

Start a subscriber (a CachedModeledFramework instance) using the Instance client template

Parameters:

instanceType - type to listen for

Returns:

CachedModeledFramework instance (already started)