|
Brooklyn | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object brooklyn.management.internal.AbstractSubscriptionManager brooklyn.management.internal.QueueingSubscriptionManager
@SuppressWarnings("rawtypes") public class QueueingSubscriptionManager extends AbstractSubscriptionManager
Field Summary | |
---|---|
AbstractSubscriptionManager |
delegate
|
boolean |
useDelegateForPublishing
|
boolean |
useDelegateForSubscribing
|
Method Summary | |
---|---|
java.util.Set
|
getSubscriptionsForEntitySensor(Entity source, Sensor sensor)
|
java.util.Set
|
getSubscriptionsForSubscriber(java.lang.Object subscriber)
|
void
|
publish(SensorEvent event)
|
void
|
setDelegate(AbstractSubscriptionManager delegate)
|
void
|
startDelegatingForPublishing()
|
void
|
startDelegatingForSubscribing()
|
void
|
stopDelegatingForPublishing()
|
void
|
stopDelegatingForSubscribing()
|
protected SubscriptionHandle
|
subscribe(java.util.Map flags, Subscription s)
|
boolean
|
unsubscribe(SubscriptionHandle subscriptionId)
|
Methods inherited from class AbstractSubscriptionManager | |
---|---|
getSubscriber, publish, subscribe, subscribe, subscribe, subscribeToChildren, subscribeToChildren, subscribeToMembers, subscribeToMembers |
Field Detail |
---|
public AbstractSubscriptionManager delegate
public boolean useDelegateForPublishing
public boolean useDelegateForSubscribing
Method Detail |
---|
@Override public java.util.Set getSubscriptionsForEntitySensor(Entity source, Sensor sensor)
@SuppressWarnings("unchecked") @Override public java.util.Set getSubscriptionsForSubscriber(java.lang.Object subscriber)
@Override public void publish(SensorEvent event)
public void setDelegate(AbstractSubscriptionManager delegate)
@SuppressWarnings("unchecked") public void startDelegatingForPublishing()
@SuppressWarnings("unchecked") public void startDelegatingForSubscribing()
public void stopDelegatingForPublishing()
public void stopDelegatingForSubscribing()
@Override protected SubscriptionHandle subscribe(java.util.Map flags, Subscription s)
@Override public boolean unsubscribe(SubscriptionHandle subscriptionId)
Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.