com.jenjinstudios.io.connection

Class Connection<C extends ExecutionContext>

java.lang.Object

com.jenjinstudios.io.connection.Connection<C>

public class Connection<C extends ExecutionContext>
extends java.lang.Object

Used for making connections so that Message objects can be read, written, and executed in a non-blocking fashion.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getId()
void	sendMessage(Message message) Send the specified Message from this connection.
void	start() Start sending, receiving, and executing messages.
void	stop() Stop sending, receiving, and executing messages, and close input and output streams.

Methods inherited from class java.lang.Object

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

Method Detail

start

public void start()

Start sending, receiving, and executing messages.

stop

public void stop()

Stop sending, receiving, and executing messages, and close input and output streams.

getId

public java.lang.String getId()

sendMessage

public void sendMessage(Message message)

Send the specified Message from this connection. Note that this operation is not atomic; the message is added to and outgoing queue, and will be sent when the thread responsible for writing outgoing messages is able to process it.

Parameters:

message - The message to be sent.