Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.transport.openwire
Class OpenWireTransportChannel  view OpenWireTransportChannel download OpenWireTransportChannel.java

java.lang.Object
  extended byorg.activemq.transport.TransportChannelSupport
      extended byorg.activemq.transport.tcp.TcpTransportChannel
          extended byorg.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 $

Field Summary
private static org.apache.commons.logging.Log log
           
 
Fields inherited from class org.activemq.transport.tcp.TcpTransportChannel
dataIn, dataOut, socket
 
Fields inherited from class org.activemq.transport.TransportChannelSupport
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally
 
Constructor Summary
OpenWireTransportChannel()
           
OpenWireTransportChannel(java.net.Socket socket, EDU.oswego.cs.dl.util.concurrent.Executor executor)
           
OpenWireTransportChannel(org.activemq.transport.tcp.TcpTransportServerChannel serverChannel, java.net.Socket socket, EDU.oswego.cs.dl.util.concurrent.Executor executor)
           
OpenWireTransportChannel(java.net.URI remoteLocation)
           
OpenWireTransportChannel(java.net.URI remoteLocation, java.net.URI localLocation)
           
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

log

private static final org.apache.commons.logging.Log log
Constructor Detail

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