org.activemq.transport.http
Class HttpTransportChannel

java.lang.Object
  extended by org.activemq.transport.TransportChannelSupport
      extended by org.activemq.transport.http.HttpTransportChannelSupport
          extended by org.activemq.transport.http.HttpTransportChannel
All Implemented Interfaces:
Runnable, org.activemq.service.Service, org.activemq.transport.TransportChannel
Direct Known Subclasses:
HttpsTransportChannel

public class HttpTransportChannel
extends HttpTransportChannelSupport

Version:
$Revision$

Field Summary
 
Fields inherited from class org.activemq.transport.TransportChannelSupport
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally
 
Constructor Summary
HttpTransportChannel(org.activemq.io.TextWireFormat wireFormat, String remoteUrl)
           
 
Method Summary
 void asyncSend(org.activemq.message.Packet packet)
           
protected  void configureConnection(HttpURLConnection connection)
           
protected  HttpURLConnection createReceiveConnection()
           
protected  HttpURLConnection createSendConnection()
           
 void forceDisconnect()
           
protected  HttpURLConnection getReceiveConnection()
           
protected  URL getRemoteURL()
           
protected  HttpURLConnection getSendConnection()
           
 boolean isMulticast()
           
 void run()
           
protected  void setReceiveConnection(HttpURLConnection conn)
           
protected  void setSendConnection(HttpURLConnection conn)
           
 void stop()
           
 
Methods inherited from class org.activemq.transport.http.HttpTransportChannelSupport
canProcessWireFormatVersion, getClosed, getCurrentWireFormatVersion, getRemoteUrl, getStarted, getTextWireFormat, getWireFormat, setClientID, setWireFormat, start, startThread, toString
 
Methods inherited from class org.activemq.transport.TransportChannelSupport
addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isTransportConnected, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setCachingEnabled, setExceptionListener, setNoDelay, 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
 

Constructor Detail

HttpTransportChannel

public HttpTransportChannel(org.activemq.io.TextWireFormat wireFormat,
                            String remoteUrl)
                     throws MalformedURLException
Throws:
MalformedURLException
Method Detail

asyncSend

public void asyncSend(org.activemq.message.Packet packet)
               throws JMSException
Throws:
JMSException

stop

public void stop()
Specified by:
stop in interface org.activemq.service.Service
Specified by:
stop in interface org.activemq.transport.TransportChannel
Overrides:
stop in class HttpTransportChannelSupport

isMulticast

public boolean isMulticast()
Specified by:
isMulticast in interface org.activemq.transport.TransportChannel
Overrides:
isMulticast in class HttpTransportChannelSupport

run

public void run()

createSendConnection

protected HttpURLConnection createSendConnection()
                                          throws IOException
Throws:
IOException

createReceiveConnection

protected HttpURLConnection createReceiveConnection()
                                             throws IOException
Throws:
IOException

configureConnection

protected void configureConnection(HttpURLConnection connection)

getRemoteURL

protected URL getRemoteURL()

getSendConnection

protected HttpURLConnection getSendConnection()
                                       throws IOException
Throws:
IOException

getReceiveConnection

protected HttpURLConnection getReceiveConnection()
                                          throws IOException
Throws:
IOException

setSendConnection

protected void setSendConnection(HttpURLConnection conn)

setReceiveConnection

protected void setReceiveConnection(HttpURLConnection conn)

forceDisconnect

public void forceDisconnect()


Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.