rescuecore2.connection

Class StreamConnection

java.lang.Object

rescuecore2.connection.AbstractConnection

rescuecore2.connection.StreamConnection

All Implemented Interfaces:

Connection

Direct Known Subclasses:

TCPConnection

public class StreamConnection
extends AbstractConnection

Connection implementation that uses InputStreams and OutputStreams.

Nested Class Summary

Nested classes/interfaces inherited from class rescuecore2.connection.AbstractConnection

AbstractConnection.State

Constructor Summary

Constructors

Constructor and Description
StreamConnection(java.io.InputStream in, java.io.OutputStream out) Create a StreamConnection.

Method Summary

Modifier and Type	Method and Description
static Pair<Connection,Connection>	createConnectionPair() Create and start a pair of connections that pipe input to each other.
boolean	isAlive() Find out if this connection is still alive.
protected void	sendBytes(byte[] b) Send some bytes to the other end of the connection.
protected void	shutdownImpl() Perform shutdown actions.
protected void	startupImpl() Perform startup actions.

Methods inherited from class rescuecore2.connection.AbstractConnection

addConnectionListener, bytesReceived, fireMessageReceived, getName, getRegistry, removeConnectionListener, sendMessage, sendMessages, setLogBytes, setName, setRegistry, shutdown, startup, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamConnection

public StreamConnection(java.io.InputStream in,
                        java.io.OutputStream out)

Create a StreamConnection.

Parameters:

in - The InputStream to read.

out - The OutputStream to write to.

Method Detail

startupImpl

protected void startupImpl()

Description copied from class: AbstractConnection

Perform startup actions. This will only ever be called once.

Specified by:

startupImpl in class AbstractConnection

isAlive

public boolean isAlive()

Description copied from interface: Connection

Find out if this connection is still alive. The connection is alive if it has been started, not stopped, and no fatal errors have occurred.

Specified by:

isAlive in interface Connection

Overrides:

isAlive in class AbstractConnection

Returns:

True if this connection is alive and is still able to send/receive messages, false otherwise.

shutdownImpl

protected void shutdownImpl()

Description copied from class: AbstractConnection

Perform shutdown actions. This will only ever be called once.

Specified by:

shutdownImpl in class AbstractConnection

sendBytes

protected void sendBytes(byte[] b)
                  throws java.io.IOException

Description copied from class: AbstractConnection

Send some bytes to the other end of the connection.

Specified by:

sendBytes in class AbstractConnection

Parameters:

b - The bytes to send.

Throws:

java.io.IOException - If the data cannot be sent.

createConnectionPair

public static Pair<Connection,Connection> createConnectionPair()

Create and start a pair of connections that pipe input to each other.

Returns:

A pair of connections.