org.apache.activemq.transport.http
Class BlockingQueueTransport
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.transport.TransportSupport
org.apache.activemq.transport.http.BlockingQueueTransport
- All Implemented Interfaces:
- Service, Transport
public class BlockingQueueTransport
- extends TransportSupport
A server side HTTP based TransportChannel which processes incoming packets
and adds outgoing packets onto a Queue
so that they can be dispatched
by the HTTP GET requests from the client.
- Version:
- $Revision$
Methods inherited from class org.apache.activemq.transport.TransportSupport |
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, narrow, onException, reconnect, request, request, setTransportListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MAX_TIMEOUT
public static final long MAX_TIMEOUT
- See Also:
- Constant Field Values
BlockingQueueTransport
public BlockingQueueTransport(BlockingQueue<Object> channel)
getQueue
public BlockingQueue<Object> getQueue()
oneway
public void oneway(Object command)
throws IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Throws:
IOException
getRemoteAddress
public String getRemoteAddress()
- Returns:
- the remote address for this connection
doStart
protected void doStart()
throws Exception
- Specified by:
doStart
in class ServiceSupport
- 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.