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