SocketConnectorUtility¶

public class SocketConnectorUtility¶

A class providing base functionality for rsb.transport.Connector implementations of the socket transport. It is intended to be used via composition. Provided methods are generally thread-safe if not indicated otherwise. The respective instance of this class is used for synchronizing in case clients of this class need to extend synchronized blocks or interact with the synchronization strategies of this class.

Author: jwienke

Constructors¶

SocketConnectorUtility¶

public SocketConnectorUtility(SocketOptions socketOptions, ServerMode serverMode, ConverterSelectionStrategy<ByteBuffer> converters)¶

Constructor.

Parameters

socketOptions – socket options to use
serverMode – the kind of server mode to use
converters – the converters to use for serialization

Methods¶

activate¶

public void activate()¶

Acquires a new Bus instance and activates it respecting the requested ServerMode.

Throws: RSBException – error initializing Bus

deactivate¶

public void deactivate()¶

Deactivates the underlying bus instance.

Throws

RSBException – error deactivating Bus
InterruptedException – interrupted while waiting for the bus to terminate

getBus¶

public Bus getBus()¶

Returns the underlying bus instance when called after activate() .

Returns: bus instance or null

getConverters¶

public ConverterSelectionStrategy<ByteBuffer> getConverters()¶

Returns the contained converters to use.

Returns: converters

isActive¶

public boolean isActive()¶

Indicates whether this class has been activated or not.

Returns: true if activated