Class SubscriptionManager

java.lang.Object

net.engio.mbassy.subscription.SubscriptionManager

public class SubscriptionManager
extends Object

The subscription managers responsibility is to consistently handle and synchronize the message listener subscription process. It provides fast lookup of existing subscriptions when another instance of an already known listener is subscribed and takes care of creating new set of subscriptions for any unknown class that defines message handlers.

Field Summary

Fields

Modifier and Type	Field	Description
private final MetadataReader	metadataReader
private final StrongConcurrentSet<Class>	nonListeners
private final ReentrantReadWriteLock	readWriteLock
private final BusRuntime	runtime
private final SubscriptionFactory	subscriptionFactory
private final Map<Class, Subscription[]>	subscriptionsPerListener
private final Map<Class, ArrayList<Subscription>>	subscriptionsPerMessage

Constructor Summary

Constructors

Constructor	Description
SubscriptionManager(MetadataReader metadataReader, SubscriptionFactory subscriptionFactory, BusRuntime runtime)

Method Summary

Modifier and Type	Method	Description
private Subscription[]	getSubscriptionsByListener(Object listener)
Collection<Subscription>	getSubscriptionsByMessageType(Class messageType)
void	subscribe(Object listener)
private void	subscribe(Object listener, Subscription[] subscriptions)
boolean	unsubscribe(Object listener)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

metadataReader

private final MetadataReader metadataReader

subscriptionsPerMessage

private final Map<Class, ArrayList<Subscription>> subscriptionsPerMessage

subscriptionsPerListener

private final Map<Class, Subscription[]> subscriptionsPerListener

nonListeners

private final StrongConcurrentSet<Class> nonListeners

subscriptionFactory

private final SubscriptionFactory subscriptionFactory

readWriteLock

private final ReentrantReadWriteLock readWriteLock

runtime

private final BusRuntime runtime

Constructor Details

SubscriptionManager

public SubscriptionManager(MetadataReader metadataReader,
 SubscriptionFactory subscriptionFactory,
 BusRuntime runtime)

Method Details

unsubscribe

public boolean unsubscribe(Object listener)

getSubscriptionsByListener

private Subscription[] getSubscriptionsByListener(Object listener)

subscribe

public void subscribe(Object listener)

subscribe

private void subscribe(Object listener,
 Subscription[] subscriptions)

getSubscriptionsByMessageType

public Collection<Subscription> getSubscriptionsByMessageType(Class messageType)