org.codehaus.activemq.transport.http
Class HttpTransportChannel

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelSupport
      extended byorg.codehaus.activemq.transport.http.HttpTransportChannelSupport
          extended byorg.codehaus.activemq.transport.http.HttpTransportChannel
All Implemented Interfaces:
Runnable, org.codehaus.activemq.service.Service, org.codehaus.activemq.transport.TransportChannel

public class HttpTransportChannel
extends HttpTransportChannelSupport

Version:
$Revision: 1.3 $

Field Summary
 
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport
pendingStop, transportConnected
 
Constructor Summary
HttpTransportChannel(org.codehaus.activemq.io.TextWireFormat wireFormat, String remoteUrl)
           
 
Method Summary
 void asyncSend(org.codehaus.activemq.message.Packet packet)
           
protected  void configureConnection(HttpURLConnection connection)
           
 void forceDisconnect()
           
protected  HttpURLConnection getReceiveConnection()
           
protected  HttpURLConnection getSendConnection()
           
 boolean isMulticast()
           
 void run()
           
 void stop()
           
 
Methods inherited from class org.codehaus.activemq.transport.http.HttpTransportChannelSupport
canProcessWireFormatVersion, getClosed, getCurrentWireFormatVersion, getRemoteUrl, getStarted, getWireFormat, setClientID, setWireFormat, start, startThread, toString
 
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport
addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, 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

HttpTransportChannel

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

asyncSend

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

stop

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

isMulticast

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

run

public void run()

getSendConnection

protected HttpURLConnection getSendConnection()
                                       throws IOException
Throws:
IOException

getReceiveConnection

protected HttpURLConnection getReceiveConnection()
                                          throws IOException
Throws:
IOException

configureConnection

protected void configureConnection(HttpURLConnection connection)

forceDisconnect

public void forceDisconnect()


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