jadex.platform.service.message.transport.niotcpmtp

Class NIOTCPInputConnection

java.lang.Object

jadex.platform.service.message.transport.niotcpmtp.NIOTCPInputConnection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class NIOTCPInputConnection
extends java.lang.Object
implements java.io.Closeable

The input connection (channel) for incoming requests.

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	msg The current result message.
protected int	msg_len The current message length (-1 for none).
protected int	msg_pos The msg pos.
protected java.nio.ByteBuffer	rb The read buffer for reading out the messages.
protected java.nio.channels.SocketChannel	sc The socket channel for receiving messages.
protected java.nio.ByteBuffer	wb The write buffer for the channel.

Constructor Summary

Constructors

Constructor and Description
NIOTCPInputConnection(java.nio.channels.SocketChannel sc) Constructor for InputConnection.

Method Summary

Modifier and Type	Method and Description
void	close() Close the connection.
byte[]	read() Read a message from the channel.
java.lang.String	toString() A string representation.

Methods inherited from class java.lang.Object

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

Field Detail

sc

protected java.nio.channels.SocketChannel sc

The socket channel for receiving messages.

wb

protected java.nio.ByteBuffer wb

The write buffer for the channel.

rb

protected java.nio.ByteBuffer rb

The read buffer for reading out the messages.

msg_len

protected int msg_len

The current message length (-1 for none).

msg

protected byte[] msg

The current result message.

msg_pos

protected int msg_pos

The msg pos.

Constructor Detail

NIOTCPInputConnection

public NIOTCPInputConnection(java.nio.channels.SocketChannel sc)

Constructor for InputConnection.

Parameters:

sc -

dec -

Throws:

java.io.IOException

Method Detail

read

public byte[] read()
            throws java.io.IOException

Read a message from the channel.

Returns:

The message if a complete message is finished.

Throws:

java.lang.Exception - on read error.

java.io.IOException

close

public void close()

Close the connection.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

toString

public java.lang.String toString()

A string representation.

Overrides:

toString in class java.lang.Object