de.netseeker.ejoe.core
Class ConnectionReader

java.lang.Object
  de.netseeker.ejoe.core.ConnectionReader

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

InJvmProcessor

public class ConnectionReader
extends java.lang.Object
implements java.lang.Runnable

ConnectionReader targets three jobs:

• Read (partial) data from a established client connection
• Invoke the server handler to process the received data
• Hand over the response to the ConnectionProcessor for further processing (sending to the client)

Since:

0.3.0

Author:

netseeker

Constructor Summary

ConnectionReader(ChannelRegistrar registrar, ServerInfo receiverInfo, ConnectionHeader senderInfo)
Creates a new instance of ConnectionReader

Method Summary

protected java.lang.Object	deserialize(SerializeAdapter adapter, java.io.InputStream in)
ServerInfo	getReceiverInfo()
ChannelRegistrar	getRegistrar()
ConnectionHeader	getSenderInfo()
protected java.lang.Object	handleObject(java.lang.Object obj)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionReader

public ConnectionReader(ChannelRegistrar registrar,
                        ServerInfo receiverInfo,
                        ConnectionHeader senderInfo)

Creates a new instance of ConnectionReader

Parameters:

channel - a socket channel ready for reading and writing

adapter - (de)serialize adapter

handler - the working horse handling the transported input object

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

getReceiverInfo

public ServerInfo getReceiverInfo()

Returns:

the _receiverInfo

getSenderInfo

public ConnectionHeader getSenderInfo()

Returns:

the _senderInfo

getRegistrar

public ChannelRegistrar getRegistrar()

Returns:

the _registrar

deserialize

protected java.lang.Object deserialize(SerializeAdapter adapter,
                                       java.io.InputStream in)
                                throws java.lang.Exception

Parameters:

clientInfo -

in -

Returns:

Throws:

java.io.IOException

java.lang.Exception

handleObject

protected java.lang.Object handleObject(java.lang.Object obj)
                                 throws java.rmi.RemoteException

Parameters:

obj -

Returns:

Throws:

java.rmi.RemoteException