RefCountingBus

public class RefCountingBus extends AbstractActivatable implements Bus

A reference counting decorator for Bus instances. The wrapped instance is activated only to the first call to activate() and deactivated only when as many deactivate() calls are received as have been activate calls received.

Author

jwienke

Constructors

RefCountingBus

public RefCountingBus(Bus bus, DeactivationHandler handler)

Constructor.

Parameters

• bus – bus to manage

• handler – handler to be called on deactivation of the bus

Methods

activate

public void activate()

addNotificationReceiver

public void addNotificationReceiver(NotificationReceiver receiver)

deactivate

public void deactivate()

getContainedBus

public Bus getContainedBus()

Returns the underlying bus that is handled with reference counting. Do not call Bus.activate() or Bus.deactivate() on this instance!

Returns

the managed bus

getSocketOptions

public SocketOptions getSocketOptions()

getTransportUri

public URI getTransportUri()

handleOutgoing

public void handleOutgoing(Notification notification)

isActive

public boolean isActive()

removeNotificationReceiver

public void removeNotificationReceiver(NotificationReceiver receiver)