rsb.transport.socket

Class BusConnection

java.lang.Object

rsb.transport.socket.BusConnection

public class BusConnection
extends java.lang.Object

Instances of this class implement connections to a socket-based bus. 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

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	HANDSHAKE

Constructor Summary

Constructors

Constructor and Description
BusConnection(java.net.InetAddress addr, int port)
BusConnection(java.net.InetAddress addr, int port, boolean isServer)

Method Summary

Methods

Modifier and Type	Method and Description
void	activate()
protected void	connect() Perform simple handshake as specified in RSB socket protocol.
void	deactivate() Safely close I/O streams and sockets.
protected int	readLength() Extract length of next notification blob.
protected Notification	readNotification() Read a single Socket transport packet (length + notification) and decode it into an RSB notification object.

Methods inherited from class java.lang.Object

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

Field Detail

HANDSHAKE

protected static final int HANDSHAKE

See Also:

Constant Field Values

Constructor Detail

BusConnection

public BusConnection(java.net.InetAddress addr,
             int port,
             boolean isServer)

BusConnection

public BusConnection(java.net.InetAddress addr,
             int port)

Method Detail

activate

public void activate()
              throws java.io.IOException,
                     RSBException

Throws:

java.io.IOException

RSBException

deactivate

public void deactivate()

Safely close I/O streams and sockets.

Throws:

RSBException

connect

protected void connect()
                throws RSBException

Perform simple handshake as specified in RSB socket protocol.

Throws:

RSBException

readLength

protected int readLength()
                  throws java.io.IOException

Extract length of next notification blob.

Returns:

Number of bytes

Throws:

java.io.IOException

readNotification

protected Notification readNotification()
                                 throws java.io.IOException

Read a single Socket transport packet (length + notification) and decode it into an RSB notification object.

Returns:

Notification object

Throws:

java.io.IOException