edu.cuny.cat.comm
Class SocketBasedCatpConnection

java.lang.Object
  edu.cuny.cat.comm.SocketBasedConnection<CatpMessage>
      edu.cuny.cat.comm.SocketBasedCatpConnection

All Implemented Interfaces:

Connection<CatpMessage>, ProactiveConnection<CatpMessage>

public class SocketBasedCatpConnection
extends SocketBasedConnection<CatpMessage>

The implementation of Connection when SocketBasedInfrastructureImpl is used.

Version:

$Revision: 1.32 $

Author:

Jinzhong Niu

Field Summary

Fields inherited from class edu.cuny.cat.comm.SocketBasedConnection

BUFFER_SIZE, readBuffer, skipLF, socketChannel

Constructor Summary

SocketBasedCatpConnection(java.nio.channels.SocketChannel socketChannel)

Method Summary

CatpMessage

getMessage() reads a Message from this connection.

Methods inherited from class edu.cuny.cat.comm.SocketBasedConnection

close, getLocalAddressInfo, getRemoteAddressInfo, initBuffer, isClosed, open, readLine, sendMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketBasedCatpConnection

public SocketBasedCatpConnection(java.nio.channels.SocketChannel socketChannel)

Method Detail

getMessage

public CatpMessage getMessage()
                       throws CatException

Description copied from interface: ProactiveConnection

reads a Message from this connection. It blocks if no messages are available.

Returns:

message received over the connection.

Throws:

MessageException

CatException