QueueingSubscriptionManager (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 QueueingSubscriptionManager

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)