org.apache.activemq.transport.http
Class HttpTransport
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.transport.TransportSupport
org.apache.activemq.transport.TransportThreadSupport
org.apache.activemq.transport.http.HttpTransportSupport
org.apache.activemq.transport.http.HttpTransport
- All Implemented Interfaces:
- Runnable, Service, Transport
- Direct Known Subclasses:
- HttpsTransport
public class HttpTransport
- extends HttpTransportSupport
- Version:
- $Revision$
Methods inherited from class org.apache.activemq.transport.TransportSupport |
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, narrow, onException, reconnect, request, request, setTransportListener |
HttpTransport
public HttpTransport(TextWireFormat wireFormat,
URI remoteUrl)
throws MalformedURLException
- Throws:
MalformedURLException
oneway
public void oneway(Object o)
throws IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Throws:
IOException
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)
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class TransportThreadSupport
- Throws:
Exception
doStop
protected void doStop(ServiceStopper stopper)
throws Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
Exception
getReceiveCounter
public int getReceiveCounter()
- Description copied from interface:
Transport
- Returns a counter which gets incremented as data is read from the transport.
It should only be used to determine if there is progress being made in reading the next command from the transport.
The value may wrap into the negative numbers.
- Returns:
- a counter which gets incremented as data is read from the transport.
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.