BioReceiver (Apache Tomcat 6.0.53 API Documentation)

Overview

Package

Class

Tree

Deprecated

Index

Help

Apache Tomcat 6.0.53

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

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:: java.lang.Runnable, ChannelReceiver, Heartbeat, ListenCallback, RxTaskPool.TaskCreator

public class BioReceiver
extends ReceiverBase
implements java.lang.Runnable, ChannelReceiver, ListenCallback
extends ReceiverBase
implements java.lang.Runnable, ChannelReceiver, ListenCallback

Author:: Filip Hanik

Field Summary
`protected static Log`	`log`
`protected java.net.ServerSocket`	`serverSocket`

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

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()` Stop listening for messages

Methods inherited from class org.apache.catalina.tribes.transport.ReceiverBase
bind, doListen, getAddress, getAutoBind, getBind, getDirect, getExecutor, getHost, getListener, getMaxTasks, getMaxThreads, getMessageListener, getMinTasks, getMinThreads, getOoBInline, getPort, getRxBufSize, getSecurePort, getSelectorTimeout, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTaskPool, getTcpListenAddress, getTcpListenPort, getTcpNoDelay, getTcpSelectorTimeout, getTcpThreadCount, getTimeout, getTxBufSize, getUseBufferPool, getWorkerThreadOptions, heartbeat, isListening, messageDataReceived, setAddress, setAutoBind, setBind, setDirect, setExecutor, setHost, setListen, setListener, setLog, setMaxTasks, setMaxThreads, setMessageListener, setMinTasks, setMinThreads, setOoBInline, setPool, setPort, setRxBufSize, setSecurePort, setSelectorTimeout, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpListenAddress, setTcpListenPort, setTcpNoDelay, setTcpSelectorTimeout, setTcpThreadCount, setTimeout, setTxBufSize, setUseBufferPool

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

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

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Methods inherited from interface org.apache.catalina.tribes.ChannelReceiver
`getHost, getMessageListener, getPort, getSecurePort, setMessageListener`

Methods inherited from interface org.apache.catalina.tribes.Heartbeat
`heartbeat`

Methods inherited from interface org.apache.catalina.tribes.io.ListenCallback
`messageDataReceived`

Field Detail

log

protected static Log log

serverSocket

protected java.net.ServerSocket serverSocket

Constructor Detail

BioReceiver

public BioReceiver()

Method Detail

start

public void start()
           throws java.io.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:: java.io.IOException

createRxTask

public AbstractRxTask createRxTask()

Specified by:: createRxTask in interface RxTaskPool.TaskCreator

getReplicationThread

protected BioReplicationTask getReplicationThread()

stop

public void stop()