|
||||||||||
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
org.codehaus.activemq.transport.jxta.JxtaTransportChannel
A JXTA implementation of a TransportChannel
Field Summary |
Fields inherited from class org.codehaus.activemq.transport.tcp.TcpTransportChannel |
socket |
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
pendingStop, transportConnected |
Constructor Summary | |
JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat,
URI remoteLocation)
Connect to a remote Node - e.g. |
|
JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat,
URI remoteLocation,
URI localLocation)
Connect to a remote Node - e.g. |
Method Summary | |
protected Socket |
createSocket(URI remoteLocation)
|
protected Socket |
createSocket(URI remoteLocation,
URI localLocation)
|
String |
toString()
pretty print for object |
Methods inherited from class org.codehaus.activemq.transport.tcp.TcpTransportChannel |
asyncSend, canProcessWireFormatVersion, doAsyncSend, forceDisconnect, getCurrentWireFormatVersion, getSocket, getSoTimeout, initialiseSocket, isChangeTimeout, isMulticast, isUseAsyncSend, run, setChangeTimeout, setSoTimeout, setUseAsyncSend, start, stop |
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, asyncSendWithReceipt, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setClientID, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stopExecutor |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat, URI remoteLocation) throws JMSException
remoteLocation
-
JMSException
public JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat, URI remoteLocation, URI localLocation) throws JMSException
remoteLocation
- localLocation
- -
e.g. local InetAddress and local port
JMSException
Method Detail |
public String toString()
protected Socket createSocket(URI remoteLocation) throws UnknownHostException, IOException
UnknownHostException
IOException
protected Socket createSocket(URI remoteLocation, URI localLocation) throws IOException, UnknownHostException
IOException
UnknownHostException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |