org.apache.catalina.tribes.transport

Class ReceiverBase

public abstract class ReceiverBase extends Object implements ChannelReceiver, ListenCallback, RxTaskPool.TaskCreator

Title:

Description:

Company:

Version: 1.0

Author: not attributable

Field Summary
protected static Loglog
static intOPTION_DIRECT_BUFFER
Constructor Summary
ReceiverBase()
Method Summary
protected intbind(ServerSocket socket, int portstart, int retries)
recursive bind to find the next available port
booleandoListen()
StringgetAddress()
intgetAutoBind()
InetAddressgetBind()
booleangetDirect()
ExecutorServicegetExecutor()
StringgetHost()
MessageListenergetListener()
intgetMaxTasks()
intgetMaxThreads()
MessageListenergetMessageListener()
getMessageListener
intgetMinTasks()
intgetMinThreads()
booleangetOoBInline()
intgetPort()
intgetRxBufSize()
intgetSecurePort()
longgetSelectorTimeout()
booleangetSoKeepAlive()
booleangetSoLingerOn()
intgetSoLingerTime()
booleangetSoReuseAddress()
intgetSoTrafficClass()
RxTaskPoolgetTaskPool()
StringgetTcpListenAddress()
intgetTcpListenPort()
booleangetTcpNoDelay()
longgetTcpSelectorTimeout()
intgetTcpThreadCount()
intgetTimeout()
intgetTxBufSize()
booleangetUseBufferPool()
intgetWorkerThreadOptions()
voidheartbeat()
booleanisListening()
voidmessageDataReceived(ChannelMessage data)
voidsetAddress(String host)
voidsetAutoBind(int autoBind)
voidsetBind(InetAddress bind)
voidsetDirect(boolean direct)
voidsetExecutor(ExecutorService executor)
voidsetHost(String host)
voidsetListen(boolean doListen)
voidsetListener(MessageListener listener)
voidsetLog(Log log)
voidsetMaxTasks(int maxTasks)
voidsetMaxThreads(int maxThreads)
voidsetMessageListener(MessageListener listener)
setMessageListener
voidsetMinTasks(int minTasks)
voidsetMinThreads(int minThreads)
voidsetOoBInline(boolean ooBInline)
voidsetPool(RxTaskPool pool)
voidsetPort(int port)
voidsetRxBufSize(int rxBufSize)
voidsetSecurePort(int securePort)
voidsetSelectorTimeout(long selTimeout)
voidsetSoKeepAlive(boolean soKeepAlive)
voidsetSoLingerOn(boolean soLingerOn)
voidsetSoLingerTime(int soLingerTime)
voidsetSoReuseAddress(boolean soReuseAddress)
voidsetSoTrafficClass(int soTrafficClass)
voidsetTcpListenAddress(String tcpListenHost)
voidsetTcpListenPort(int tcpListenPort)
voidsetTcpNoDelay(boolean tcpNoDelay)
voidsetTcpSelectorTimeout(long selTimeout)
voidsetTcpThreadCount(int tcpThreadCount)
voidsetTimeout(int timeout)
voidsetTxBufSize(int txBufSize)
voidsetUseBufferPool(boolean useBufferPool)
voidstart()
voidstop()

Field Detail

log

protected static Log log

OPTION_DIRECT_BUFFER

public static final int OPTION_DIRECT_BUFFER

Constructor Detail

ReceiverBase

public ReceiverBase()

Method Detail

bind

protected int bind(ServerSocket socket, int portstart, int retries)
recursive bind to find the next available port

Parameters: socket ServerSocket portstart int retries int

Returns: int

Throws: IOException

doListen

public boolean doListen()

getAddress

public String getAddress()

getAutoBind

public int getAutoBind()

getBind

public InetAddress getBind()

Returns: Returns the bind.

getDirect

public boolean getDirect()

getExecutor

public ExecutorService getExecutor()

getHost

public String getHost()

getListener

public MessageListener getListener()

getMaxTasks

public int getMaxTasks()

getMaxThreads

public int getMaxThreads()

getMessageListener

public MessageListener getMessageListener()
getMessageListener

Returns: MessageListener

UNKNOWN: Implement this org.apache.catalina.tribes.ChannelReceiver method

getMinTasks

public int getMinTasks()

getMinThreads

public int getMinThreads()

getOoBInline

public boolean getOoBInline()

getPort

public int getPort()

Returns: The port

UNKNOWN: Implement this org.apache.catalina.tribes.ChannelReceiver method

getRxBufSize

public int getRxBufSize()

getSecurePort

public int getSecurePort()

getSelectorTimeout

public long getSelectorTimeout()

getSoKeepAlive

public boolean getSoKeepAlive()

getSoLingerOn

public boolean getSoLingerOn()

getSoLingerTime

public int getSoLingerTime()

getSoReuseAddress

public boolean getSoReuseAddress()

getSoTrafficClass

public int getSoTrafficClass()

getTaskPool

public RxTaskPool getTaskPool()

getTcpListenAddress

public String getTcpListenAddress()

Deprecated: use getAddress

Returns: String

getTcpListenPort

public int getTcpListenPort()

Deprecated: use getPort

Returns: int

getTcpNoDelay

public boolean getTcpNoDelay()

getTcpSelectorTimeout

public long getTcpSelectorTimeout()

Deprecated: use getSelectorTimeout

Returns: long

getTcpThreadCount

public int getTcpThreadCount()

Deprecated: use getMinThreads()/getMaxThreads()

Returns: int

getTimeout

public int getTimeout()

getTxBufSize

public int getTxBufSize()

getUseBufferPool

public boolean getUseBufferPool()

getWorkerThreadOptions

public int getWorkerThreadOptions()

heartbeat

public void heartbeat()

isListening

public boolean isListening()

messageDataReceived

public void messageDataReceived(ChannelMessage data)

setAddress

public void setAddress(String host)

setAutoBind

public void setAutoBind(int autoBind)

setBind

public void setBind(InetAddress bind)

Parameters: bind The bind to set.

setDirect

public void setDirect(boolean direct)

setExecutor

public void setExecutor(ExecutorService executor)

setHost

public void setHost(String host)

setListen

public void setListen(boolean doListen)

setListener

public void setListener(MessageListener listener)

setLog

public void setLog(Log log)

setMaxTasks

public void setMaxTasks(int maxTasks)

setMaxThreads

public void setMaxThreads(int maxThreads)

setMessageListener

public void setMessageListener(MessageListener listener)
setMessageListener

Parameters: listener MessageListener

UNKNOWN: Implement this org.apache.catalina.tribes.ChannelReceiver method

setMinTasks

public void setMinTasks(int minTasks)

setMinThreads

public void setMinThreads(int minThreads)

setOoBInline

public void setOoBInline(boolean ooBInline)

setPool

public void setPool(RxTaskPool pool)

setPort

public void setPort(int port)

setRxBufSize

public void setRxBufSize(int rxBufSize)

setSecurePort

public void setSecurePort(int securePort)

setSelectorTimeout

public void setSelectorTimeout(long selTimeout)

setSoKeepAlive

public void setSoKeepAlive(boolean soKeepAlive)

setSoLingerOn

public void setSoLingerOn(boolean soLingerOn)

setSoLingerTime

public void setSoLingerTime(int soLingerTime)

setSoReuseAddress

public void setSoReuseAddress(boolean soReuseAddress)

setSoTrafficClass

public void setSoTrafficClass(int soTrafficClass)

setTcpListenAddress

public void setTcpListenAddress(String tcpListenHost)

Deprecated: use setAddress

Parameters: tcpListenHost String

setTcpListenPort

public void setTcpListenPort(int tcpListenPort)

Deprecated: use setPort

Parameters: tcpListenPort int

setTcpNoDelay

public void setTcpNoDelay(boolean tcpNoDelay)

setTcpSelectorTimeout

public void setTcpSelectorTimeout(long selTimeout)

Deprecated: use setSelectorTimeout

Parameters: selTimeout long

setTcpThreadCount

public void setTcpThreadCount(int tcpThreadCount)

Deprecated: use setMaxThreads/setMinThreads

Parameters: tcpThreadCount int

setTimeout

public void setTimeout(int timeout)

setTxBufSize

public void setTxBufSize(int txBufSize)

setUseBufferPool

public void setUseBufferPool(boolean useBufferPool)

start

public void start()

stop

public void stop()
Copyright © 2000-2011 Apache Software Foundation. All Rights Reserved.