rsb.transport.socket

Class BusServerConnection

java.lang.Object

rsb.AbstractActivatable

rsb.transport.socket.BusConnectionBase

rsb.transport.socket.BusServerConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Activatable, BusConnection

public class BusServerConnection
extends BusConnectionBase

Instances of this class implement connections to a socket-based bus in the form of a server. The basic operations provided by this class are receiving an event notifications by calling receiveNotification and submitting an event to the bus by calling sendNotification. This class implements the fundamental RSB protocol for socket connections, e.g., the basic handshaking and the encoding/decoding of data packages for event notifications.

Author:

swrede

See Also:

RSB Specification for Socket Transport

Nested Class Summary

Nested classes/interfaces inherited from interface rsb.Activatable

Activatable.State

Constructor Summary

Constructors

Constructor and Description
BusServerConnection(Socket socket, boolean tcpNoDelay) Constructs a new server.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	handshake() Performs the handshake step of the protocol.

Methods inherited from class rsb.transport.socket.BusConnectionBase

activate, deactivate, getOptions, getReader, getSocket, getWriter, isActive, isActiveShutdown, readLength, readNotification, sendNotification, setOptions, setSocket, shutdown

Methods inherited from class rsb.AbstractActivatable

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

BusServerConnection

public BusServerConnection(Socket socket,
                   boolean tcpNoDelay)

Constructs a new server.

Parameters:

socket - socket to use for the server side. This is usually the result of calling ServerSocket.accept().

tcpNoDelay - if true, configure the socket to use tcp no delay

Method Detail

handshake

protected void handshake()
                  throws RSBException

Description copied from class: BusConnectionBase

Performs the handshake step of the protocol.

Specified by:

handshake in class BusConnectionBase

Throws:

RSBException - error during handshake