|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.TransportChannelSupport
org.codehaus.activemq.transport.tcp.TcpTransportChannel
A tcp implementation of a TransportChannel
Field Summary | |
protected Socket |
socket
|
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
pendingStop, transportConnected |
Constructor Summary | |
protected |
TcpTransportChannel(WireFormat wireFormat)
Construct basic helpers |
|
TcpTransportChannel(WireFormat wireFormat,
Socket socket,
Executor executor)
|
|
TcpTransportChannel(WireFormat wireFormat,
URI remoteLocation)
Connect to a remote Node - e.g. |
|
TcpTransportChannel(WireFormat wireFormat,
URI remoteLocation,
URI localLocation)
Connect to a remote Node - e.g. |
Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
protected Socket |
createSocket(URI remoteLocation)
Factory method to create a new socket |
protected Socket |
createSocket(URI remoteLocation,
URI localLocation)
Factory method to create a new socket |
protected void |
doAsyncSend(Packet packet)
Actually performs the async send of a packet |
void |
forceDisconnect()
Forces an immediate transport-level disconnect which will be asynchronously reported as an exception to the exceptionListener. |
int |
getCurrentWireFormatVersion()
|
Socket |
getSocket()
|
int |
getSoTimeout()
|
protected void |
initialiseSocket()
Configures the socket for use |
boolean |
isChangeTimeout()
|
boolean |
isMulticast()
|
boolean |
isUseAsyncSend()
|
void |
run()
reads packets from a Socket |
void |
setChangeTimeout(boolean changeTimeout)
Set the changeTimeout flag - if set the timeout value is changed after receiving a packet When receiving a packet, so timeout is set to zero (inifinite) after receiving the first byte, which determines the packet type. |
void |
setSoTimeout(int soTimeout)
set the socket so timeout |
void |
setUseAsyncSend(boolean useAsyncSend)
set the useAsync flag |
void |
start()
start listeneing for events |
void |
stop()
close the channel |
String |
toString()
pretty print for object |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
protected Socket socket
Constructor Detail |
protected TcpTransportChannel(WireFormat wireFormat)
wireFormat
- public TcpTransportChannel(WireFormat wireFormat, URI remoteLocation) throws JMSException
wireFormat
- remoteLocation
-
JMSException
public TcpTransportChannel(WireFormat wireFormat, URI remoteLocation, URI localLocation) throws JMSException
wireFormat
- remoteLocation
- localLocation
- - e.g. local InetAddress and local port
JMSException
public TcpTransportChannel(WireFormat wireFormat, Socket socket, Executor executor) throws JMSException
wireFormat
- socket
- executor
-
JMSException
Method Detail |
public void start() throws JMSException
start
in interface TransportChannel
JMSException
- if an error occurspublic void stop()
stop
in interface TransportChannel
stop
in class TransportChannelSupport
public void forceDisconnect()
TransportChannel
forceDisconnect
in interface TransportChannel
public void asyncSend(Packet packet) throws JMSException
asyncSend
in interface TransportChannel
packet
-
JMSException
public boolean isMulticast()
isMulticast
in interface TransportChannel
isMulticast
in class TransportChannelSupport
public void run()
run
in interface Runnable
public String toString()
public Socket getSocket()
public boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion
in interface TransportChannel
canProcessWireFormatVersion
in class TransportChannelSupport
version
- the version number to test
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion
in interface TransportChannel
getCurrentWireFormatVersion
in class TransportChannelSupport
public boolean isChangeTimeout()
public void setChangeTimeout(boolean changeTimeout)
changeTimeout
- public boolean isUseAsyncSend()
public void setUseAsyncSend(boolean useAsyncSend)
useAsyncSend
- public int getSoTimeout()
public void setSoTimeout(int soTimeout)
soTimeout
- protected void doAsyncSend(Packet packet) throws JMSException
doAsyncSend
in class TransportChannelSupport
packet
-
JMSException
protected void initialiseSocket() throws IOException
IOException
protected Socket createSocket(URI remoteLocation) throws UnknownHostException, IOException
remoteLocation
- the URI to connect to
UnknownHostException
IOException
protected Socket createSocket(URI remoteLocation, URI localLocation) throws IOException, UnknownHostException
remoteLocation
- localLocation
-
IOException
UnknownHostException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |