BusCache

public class BusCache

A cache for Bus instances based on the required SocketOptions . This class is thread-safe. For longer synchronized blocks use getSynchronizer().

Author

jwienke

Methods

get

public Bus get(SocketOptions options)

Returns a Bus instance for the given options or null if no such instance is cached.

Parameters

options – options to look up

Returns

Bus instance or null

getSynchronizer

public Object getSynchronizer()

Clients may use the returned instance to synchronize on.

Returns

object to synchronize on

hasBus

public boolean hasBus(SocketOptions options)

Indicates whether a Bus instance with the given options is available or not.

Parameters

options – options to look up

Returns

true if available, else false

register

public void register(Bus bus)

Registers a new bus instance in the cache.

Parameters

bus – bus to register

Throws

IllegalArgumentException – there is already a bus with the given options

register

public void register(Bus bus, boolean replace)

Registers a new bus instance in the cache and allows overriding existing instances.

Parameters

• bus – bus to registers

• replace – if true, replace existing instances with the same options instead of throwing an exception

Throws

IllegalArgumentException – there is already a bus with the given options and replacing was not requested

unregister

public void unregister(Bus bus)

Removes a bus from the cache if it was present.

Parameters

bus – the bus to remove