LocalSubscriptionManager (Brooklyn)

Overview

Package

Class

Deprecated

Index

Help

Brooklyn

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

brooklyn.management.internal
[Java] Class LocalSubscriptionManager

java.lang.Object
  brooklyn.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

allSubscriptions

@SuppressWarnings("rawtypes")
protected final java.util.concurrent.ConcurrentMap allSubscriptions

em

protected final ExecutionManager em

subscriptionsBySubscriber

@SuppressWarnings("rawtypes")
protected final java.util.concurrent.ConcurrentMap subscriptionsBySubscriber

subscriptionsByToken

@SuppressWarnings("rawtypes")
protected final java.util.concurrent.ConcurrentMap subscriptionsByToken

Constructor Detail

LocalSubscriptionManager

public LocalSubscriptionManager(ExecutionManager m)

Method Detail

getNumSubscriptions

public long getNumSubscriptions()

getSubscriptionsForEntitySensor

public java.util.Set getSubscriptionsForEntitySensor(Entity source, Sensor sensor)

getSubscriptionsForSubscriber

@SuppressWarnings("unchecked")
public java.util.Set getSubscriptionsForSubscriber(java.lang.Object subscriber)

getTotalEventsDelivered

public long getTotalEventsDelivered()

getTotalEventsPublished

public long getTotalEventsPublished()

publish

public void publish(SensorEvent event)

@SuppressWarnings("unchecked")
protected SubscriptionHandle subscribe(java.util.Map flags, Subscription s)

toString

*
public java.lang.String toString()

unsubscribe

@SuppressWarnings("rawtypes")
public boolean unsubscribe(SubscriptionHandle sh)

Unsubscribe the given subscription id.

See Also:: subscribe(Map, Entity, Sensor, SensorEventListener)

brooklyn.management.internal [Java] Class LocalSubscriptionManager