java.lang.Object
org.activemq.transport.TransportChannelSupport
org.activemq.transport.tcp.TcpTransportChannel
org.activemq.transport.openwire.OpenWireTransportChannel
- All Implemented Interfaces:
- java.lang.Runnable, org.activemq.service.Service, org.activemq.transport.TransportChannel
- public class OpenWireTransportChannel
- extends org.activemq.transport.tcp.TcpTransportChannel
A transport for using the OpenWire transport protocol.
- Version:
- $Revision: 1.1 $
| Methods inherited from class org.activemq.transport.tcp.TcpTransportChannel |
asyncSend, canProcessWireFormatVersion, closeStreams, createSocket, createSocket, doAsyncSend, doClose, forceDisconnect, getCurrentWireFormatVersion, getSocket, getSocketBufferSize, getSoTimeout, initialiseSocket, initializeStreams, isClosed, isMulticast, isUseAsyncSend, readWireFormat, run, setNoDelay, setSocketBufferSize, setSoTimeout, setUseAsyncSend, start, stop, toString |
| Methods inherited from class org.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, asyncSendWithReceipt, doConsumePacket, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, getWireFormat, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isTransportConnected, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setCachingEnabled, setClientID, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, setUsedInternally, setWireFormat, stopExecutor |
log
private static final org.apache.commons.logging.Log log
OpenWireTransportChannel
public OpenWireTransportChannel()
OpenWireTransportChannel
public OpenWireTransportChannel(java.net.URI remoteLocation)
throws javax.jms.JMSException
OpenWireTransportChannel
public OpenWireTransportChannel(java.net.URI remoteLocation,
java.net.URI localLocation)
throws javax.jms.JMSException
OpenWireTransportChannel
public OpenWireTransportChannel(org.activemq.transport.tcp.TcpTransportServerChannel serverChannel,
java.net.Socket socket,
EDU.oswego.cs.dl.util.concurrent.Executor executor)
throws javax.jms.JMSException
OpenWireTransportChannel
public OpenWireTransportChannel(java.net.Socket socket,
EDU.oswego.cs.dl.util.concurrent.Executor executor)
throws javax.jms.JMSException