|
||||||||||
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.http.HttpTransportChannelSupport
org.codehaus.activemq.transport.http.HttpTransportChannel
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 |
public HttpTransportChannel(org.codehaus.activemq.io.TextWireFormat wireFormat, String remoteUrl) throws MalformedURLException
Method Detail |
public void asyncSend(org.codehaus.activemq.message.Packet packet) throws JMSException
JMSException
public void stop()
stop
in interface org.codehaus.activemq.transport.TransportChannel
stop
in class HttpTransportChannelSupport
public boolean isMulticast()
isMulticast
in interface org.codehaus.activemq.transport.TransportChannel
isMulticast
in class HttpTransportChannelSupport
public void run()
protected HttpURLConnection getSendConnection() throws IOException
IOException
protected HttpURLConnection getReceiveConnection() throws IOException
IOException
protected void configureConnection(HttpURLConnection connection)
public void forceDisconnect()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |