Class MultipointBioSender
- java.lang.Object
-
- org.apache.catalina.tribes.transport.AbstractSender
-
- org.apache.catalina.tribes.transport.bio.MultipointBioSender
-
- All Implemented Interfaces:
DataSender
,MultiPointSender
public class MultipointBioSender extends AbstractSender implements MultiPointSender
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.HashMap<Member,BioSender>
bioSenders
-
Constructor Summary
Constructors Constructor Description MultipointBioSender()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(Member member)
void
connect()
connectvoid
disconnect()
disconnect TODO Implement this org.apache.catalina.tribes.transport.DataSender methodprotected void
finalize()
boolean
keepalive()
keepalivevoid
remove(Member member)
void
sendMessage(Member[] destination, ChannelMessage msg)
protected BioSender[]
setupForSend(Member[] destination)
-
Methods inherited from class org.apache.catalina.tribes.transport.AbstractSender
getAddress, getAttempt, getConnectTime, getDestination, getDirectBuffer, getKeepAliveCount, getKeepAliveTime, getMaxRetryAttempts, getOoBInline, getPort, getRequestCount, getRxBufSize, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTcpNoDelay, getThrowOnFailedAck, getTimeout, getTxBufSize, getUdpPort, getUdpRxBufSize, getUdpTxBufSize, isConnected, isUdpBased, setAddress, setAttempt, setConnected, setConnectTime, setDestination, setDirectBuffer, setKeepAliveCount, setKeepAliveTime, setMaxRetryAttempts, setOoBInline, setPort, setRequestCount, setRxBufSize, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpNoDelay, setThrowOnFailedAck, setTimeout, setTxBufSize, setUdpBased, setUdpPort, setUdpRxBufSize, setUdpTxBufSize, transferProperties
-
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.catalina.tribes.transport.DataSender
getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSize
-
Methods inherited from interface org.apache.catalina.tribes.transport.MultiPointSender
setDirectBuffer, setMaxRetryAttempts
-
-
-
-
Method Detail
-
sendMessage
public void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException
- Specified by:
sendMessage
in interfaceMultiPointSender
- Throws:
ChannelException
-
setupForSend
protected BioSender[] setupForSend(Member[] destination) throws ChannelException
- Throws:
ChannelException
-
connect
public void connect() throws java.io.IOException
Description copied from class:AbstractSender
connect- Specified by:
connect
in interfaceDataSender
- Specified by:
connect
in classAbstractSender
- Throws:
java.io.IOException
- TODO Implement this org.apache.catalina.tribes.transport.DataSender method
-
add
public void add(Member member)
- Specified by:
add
in interfaceMultiPointSender
-
remove
public void remove(Member member)
- Specified by:
remove
in interfaceMultiPointSender
-
disconnect
public void disconnect()
Description copied from class:AbstractSender
disconnect TODO Implement this org.apache.catalina.tribes.transport.DataSender method- Specified by:
disconnect
in interfaceDataSender
- Specified by:
disconnect
in classAbstractSender
-
finalize
protected void finalize() throws java.lang.Throwable
- Overrides:
finalize
in classjava.lang.Object
- Throws:
java.lang.Throwable
-
keepalive
public boolean keepalive()
Description copied from class:AbstractSender
keepalive- Specified by:
keepalive
in interfaceDataSender
- Overrides:
keepalive
in classAbstractSender
- Returns:
- boolean TODO Implement this org.apache.catalina.tribes.transport.DataSender method
-
-