BusConnectionBase

public abstract class BusConnectionBase extends AbstractActivatable implements BusConnection

Utility base class for the implementation of the BusConnection interface. Subclasses need to use this object for synchronization. Subclasses need to call setSocket(Socket) with a valid socket before activate() will be called. activate() will automatically call handshake().

Author

jwienke

Methods

activate

public void activate()

deactivate

public void deactivate()

getOptions

public SocketOptions getOptions()

getReader

protected ReadableByteChannel getReader()

Returns the reader for the internal socket.

Returns

reader instance or null if called before activate()

getSocket

public Socket getSocket()

Returns the contained socket instance.

Returns

socket instance or null if not set yet.

getWriter

protected WritableByteChannel getWriter()

Returns the writer for the internal socket.

Returns

writer instance or null if called before activate()

handshake

protected abstract void handshake()

Performs the handshake step of the protocol.

Throws

RSBException – error during handshake

isActive

public boolean isActive()

isActiveShutdown

public boolean isActiveShutdown()

readLength

protected int readLength()

Extract length of next notification blob.

Throws

IOException – error while reading from the socket

Returns

Number of bytes

readNotification

public Notification readNotification()

sendNotification

public void sendNotification(Notification notification)

setOptions

protected void setOptions(SocketOptions options)

Sets the options for the socket to hold in this instance.

Parameters

options – socket options to hold

setSocket

protected void setSocket(Socket socket)

Sets the internal socket instance.

Parameters

socket – new socket instance

shutdown

public void shutdown()