org.apache.catalina.tribes.transport.bio
Class BioReceiver

java.lang.Object
  org.apache.catalina.tribes.transport.ReceiverBase
      org.apache.catalina.tribes.transport.bio.BioReceiver

All Implemented Interfaces:

Runnable, ChannelReceiver, Heartbeat, ListenCallback, RxTaskPool.TaskCreator

public class BioReceiver
extends ReceiverBase
implements Runnable

Version:

$Id: BioReceiver.java 992409 2010-09-03 18:35:59Z markt $

Author:

Filip Hanik

Field Summary

protected ServerSocket

serverSocket

Fields inherited from class org.apache.catalina.tribes.transport.ReceiverBase

OPTION_DIRECT_BUFFER

Fields inherited from interface org.apache.catalina.tribes.ChannelReceiver

MAX_UDP_SIZE

Constructor Summary

BioReceiver()

Method Summary

protected void	bind()
AbstractRxTask	createRxTask()
protected BioReplicationTask	getReplicationThread()
void	listen()
void	run()
void	start() Start listening for incoming messages on the host/port
void	stop() TODO Implement this org.apache.catalina.tribes.ChannelReceiver method

Methods inherited from class org.apache.catalina.tribes.transport.ReceiverBase

bind, bindUdp, doListen, getAddress, getAutoBind, getBind, getDirect, getExecutor, getHost, getListener, getMaxIdleTime, getMaxTasks, getMaxThreads, getMessageListener, getMinTasks, getMinThreads, getOoBInline, getPort, getRxBufSize, getSecurePort, getSelectorTimeout, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTaskPool, getTcpListenAddress, getTcpListenPort, getTcpNoDelay, getTcpSelectorTimeout, getTcpThreadCount, getTimeout, getTxBufSize, getUdpPort, getUdpRxBufSize, getUdpTxBufSize, getUseBufferPool, getWorkerThreadOptions, heartbeat, isDaemon, isListening, messageDataReceived, setAddress, setAutoBind, setBind, setDaemon, setDirect, setExecutor, setHost, setListen, setListener, setMaxIdleTime, setMaxTasks, setMaxThreads, setMessageListener, setMinTasks, setMinThreads, setOoBInline, setPool, setPort, setRxBufSize, setSecurePort, setSelectorTimeout, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpListenAddress, setTcpListenPort, setTcpNoDelay, setTcpSelectorTimeout, setTcpThreadCount, setTimeout, setTxBufSize, setUdpPort, setUdpRxBufSize, setUdpTxBufSize, setUseBufferPool

Methods inherited from class java.lang.Object

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

Field Detail

serverSocket

protected ServerSocket serverSocket

Constructor Detail

BioReceiver

public BioReceiver()

Method Detail

start

public void start()
           throws IOException

Description copied from interface: ChannelReceiver

Start listening for incoming messages on the host/port

Specified by:

start in interface ChannelReceiver

Overrides:

start in class ReceiverBase

Throws:

IOException - TODO Implement this org.apache.catalina.tribes.ChannelReceiver method

createRxTask

public AbstractRxTask createRxTask()

Specified by:

createRxTask in interface RxTaskPool.TaskCreator

getReplicationThread

protected BioReplicationTask getReplicationThread()

stop

public void stop()

TODO Implement this org.apache.catalina.tribes.ChannelReceiver method

Specified by:

stop in interface ChannelReceiver

Overrides:

stop in class ReceiverBase

bind

protected void bind()
             throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

listen

public void listen()
            throws Exception

Throws:

Exception