org.ow2.petals.transport.platform.nio.server
Class NioServerAgent

java.lang.Object
  org.ow2.petals.transport.platform.nio.server.NioServerAgent

All Implemented Interfaces:

NioServer

public class NioServerAgent
extends java.lang.Object
implements NioServer

The server agent of the NIO transporter.

Author:

Christophe DENEUX (Capgemini Sud)

Field Summary

protected ConfigurationService	configurationService Interface used to access configuration
protected NioReceiver	messageReceiver
protected NioSelector	selectorAgent The socket selector Fractal component to use to process network IO.

Constructor Summary

NioServerAgent()

Method Summary

void	onClose(java.nio.channels.SocketChannel socketChannel)
void	onConnectionIsAccepted(java.nio.channels.SocketChannel socketChannel, java.nio.channels.Selector selector)
void	onRead(PipedDeserializer deserializer)
protected void	start()
protected void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

selectorAgent

protected NioSelector selectorAgent

The socket selector Fractal component to use to process network IO.

messageReceiver

protected NioReceiver messageReceiver

configurationService

protected ConfigurationService configurationService

Interface used to access configuration

Constructor Detail

NioServerAgent

public NioServerAgent()

Method Detail

start

protected void start()
              throws java.io.IOException

Throws:

java.io.IOException

stop

protected void stop()
             throws java.lang.Exception

Throws:

java.lang.Exception

onConnectionIsAccepted

public void onConnectionIsAccepted(java.nio.channels.SocketChannel socketChannel,
                                   java.nio.channels.Selector selector)
                            throws java.io.IOException

Specified by:

onConnectionIsAccepted in interface NioServer

Throws:

java.io.IOException

onRead

public void onRead(PipedDeserializer deserializer)

Specified by:

onRead in interface NioServer

onClose

public void onClose(java.nio.channels.SocketChannel socketChannel)

Specified by:

onClose in interface NioServer