QueueingSubscriptionManager (Apache Brooklyn)

java.lang.Object
- brooklyn.management.internal.AbstractSubscriptionManager
- - brooklyn.management.internal.QueueingSubscriptionManager

All Implemented Interfaces:: SubscriptionManager

public class QueueingSubscriptionManager
extends AbstractSubscriptionManager

Nested Class Summary
- Nested classes/interfaces inherited from class brooklyn.management.internal.AbstractSubscriptionManager
  AbstractSubscriptionManager.EntitySensorToken

Field Summary

Fields
Modifier and Type Field and Description

AbstractSubscriptionManager delegate

boolean useDelegateForPublishing

boolean useDelegateForSubscribing

Fields
Modifier and Type	Field and Description
`AbstractSubscriptionManager`	`delegate`
`boolean`	`useDelegateForPublishing`
`boolean`	`useDelegateForSubscribing`

Constructor Summary

Constructors
Constructor and Description

QueueingSubscriptionManager()

Constructors
Constructor and Description
`QueueingSubscriptionManager()`

Method Summary

Methods
Modifier and Type	Method and Description
`java.util.Set<SubscriptionHandle>`	`getSubscriptionsForEntitySensor(Entity source, Sensor<?> sensor)` Return the subscriptions on a given source-sensor pair
`java.util.Set<SubscriptionHandle>`	`getSubscriptionsForSubscriber(java.lang.Object subscriber)` Return the subscriptions requested by a given subscriber
`<T> void`	`publish(SensorEvent<T> event)` performs the actual publishing -- ie distribution to subscriptions
`void`	`setDelegate(AbstractSubscriptionManager delegate)`
`void`	`startDelegatingForPublishing()`
`void`	`startDelegatingForSubscribing()`
`void`	`stopDelegatingForPublishing()`
`void`	`stopDelegatingForSubscribing()`
`boolean`	`unsubscribe(SubscriptionHandle subscriptionId)` Unsubscribe the given subscription id.

Methods inherited from class brooklyn.management.internal.AbstractSubscriptionManager
subscribe, subscribe, subscribeToChildren, subscribeToChildren, subscribeToMembers, subscribeToMembers

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

- Field Detail
  - delegate
```
public AbstractSubscriptionManager delegate
```
  - useDelegateForSubscribing
```
public boolean useDelegateForSubscribing
```
  - useDelegateForPublishing
```
public boolean useDelegateForPublishing
```
- Constructor Detail
  - QueueingSubscriptionManager
```
public QueueingSubscriptionManager()
```
- Method Detail
  - publish
```
public <T> void publish(SensorEvent<T> event)
```
    Description copied from class: AbstractSubscriptionManager
    
    performs the actual publishing -- ie distribution to subscriptions
    
    Specified by:
    
    publish in interface SubscriptionManager
    
    Specified by:
    
    publish in class AbstractSubscriptionManager
  - setDelegate
```
public void setDelegate(AbstractSubscriptionManager delegate)
```
  - startDelegatingForSubscribing
```
public void startDelegatingForSubscribing()
```
  - startDelegatingForPublishing
```
public void startDelegatingForPublishing()
```
  - stopDelegatingForSubscribing
```
public void stopDelegatingForSubscribing()
```
  - stopDelegatingForPublishing
```
public void stopDelegatingForPublishing()
```
  - unsubscribe
```
public boolean unsubscribe(SubscriptionHandle subscriptionId)
```
    Description copied from interface: SubscriptionManager
    
    Unsubscribe the given subscription id.
    
    Returns:
    true if such a subscription was present (and it will now be removed)
    See Also:
    SubscriptionManager.subscribe(Map, Entity, Sensor, SensorEventListener)
  - getSubscriptionsForSubscriber
```
public java.util.Set<SubscriptionHandle> getSubscriptionsForSubscriber(java.lang.Object subscriber)
```
    Description copied from interface: SubscriptionManager
    
    Return the subscriptions requested by a given subscriber
  - getSubscriptionsForEntitySensor
```
public java.util.Set<SubscriptionHandle> getSubscriptionsForEntitySensor(Entity source,
                                                                Sensor<?> sensor)
```
    Description copied from interface: SubscriptionManager
    
    Return the subscriptions on a given source-sensor pair

Class QueueingSubscriptionManager

Nested Class Summary

Nested classes/interfaces inherited from class brooklyn.management.internal.AbstractSubscriptionManager

Field Summary

Constructor Summary

Method Summary

Methods inherited from class brooklyn.management.internal.AbstractSubscriptionManager

Methods inherited from class java.lang.Object

Field Detail

delegate

useDelegateForSubscribing

useDelegateForPublishing

Constructor Detail

QueueingSubscriptionManager

Method Detail

publish

setDelegate

startDelegatingForSubscribing

startDelegatingForPublishing

stopDelegatingForSubscribing

stopDelegatingForPublishing

unsubscribe

getSubscriptionsForSubscriber

getSubscriptionsForEntitySensor