|
Brooklyn | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbrooklyn.management.internal.AbstractSubscriptionManager
brooklyn.management.internal.LocalSubscriptionManager
public class LocalSubscriptionManager extends AbstractSubscriptionManager
A SubscriptionManager that stores subscription details locally.
Field Summary | |
---|---|
protected java.util.concurrent.ConcurrentMap |
allSubscriptions
|
protected ExecutionManager |
em
|
protected java.util.concurrent.ConcurrentMap |
subscriptionsBySubscriber
|
protected java.util.concurrent.ConcurrentMap |
subscriptionsByToken
|
Constructor Summary | |
LocalSubscriptionManager(ExecutionManager m)
|
Method Summary | |
---|---|
long
|
getNumSubscriptions()
|
java.util.Set
|
getSubscriptionsForEntitySensor(Entity source, Sensor sensor)
|
java.util.Set
|
getSubscriptionsForSubscriber(java.lang.Object subscriber)
|
long
|
getTotalEventsDelivered()
|
long
|
getTotalEventsPublished()
|
void
|
publish(SensorEvent event)
|
protected SubscriptionHandle
|
subscribe(java.util.Map flags, Subscription s)
|
java.lang.String
|
toString()
|
boolean
|
unsubscribe(SubscriptionHandle sh)
Unsubscribe the given subscription id. |
Methods inherited from class AbstractSubscriptionManager | |
---|---|
getSubscriber, publish, subscribe, subscribe, subscribe, subscribeToChildren, subscribeToChildren, subscribeToMembers, subscribeToMembers |
Field Detail |
---|
@SuppressWarnings("rawtypes") protected final java.util.concurrent.ConcurrentMap allSubscriptions
protected final ExecutionManager em
@SuppressWarnings("rawtypes") protected final java.util.concurrent.ConcurrentMap subscriptionsBySubscriber
@SuppressWarnings("rawtypes") protected final java.util.concurrent.ConcurrentMap subscriptionsByToken
Constructor Detail |
---|
public LocalSubscriptionManager(ExecutionManager m)
Method Detail |
---|
public long getNumSubscriptions()
public java.util.Set getSubscriptionsForEntitySensor(Entity source, Sensor sensor)
@SuppressWarnings("unchecked") public java.util.Set getSubscriptionsForSubscriber(java.lang.Object subscriber)
public long getTotalEventsDelivered()
public long getTotalEventsPublished()
@SuppressWarnings({ "unchecked", "rawtypes" }) public void publish(SensorEvent event)
@SuppressWarnings("unchecked") protected SubscriptionHandle subscribe(java.util.Map flags, Subscription s)
@Override public java.lang.String toString()
@SuppressWarnings("rawtypes") public boolean unsubscribe(SubscriptionHandle sh)
Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.