org.apache.activemq.transport.http
Class BlockingQueueTransport

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.transport.TransportSupport
          extended by 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.


Field Summary
static long MAX_TIMEOUT
           
 
Constructor Summary
BlockingQueueTransport(BlockingQueue<Object> channel)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 BlockingQueue<Object> getQueue()
           
 int getReceiveCounter()
          Returns a counter which gets incremented as data is read from the transport.
 String getRemoteAddress()
           
 void oneway(Object command)
          A one way asynchronous send
 
Methods inherited from class org.apache.activemq.transport.TransportSupport
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, updateURIs
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

Field Detail

MAX_TIMEOUT

public static final long MAX_TIMEOUT
See Also:
Constant Field Values
Constructor Detail

BlockingQueueTransport

public BlockingQueueTransport(BlockingQueue<Object> channel)
Method Detail

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-2013 The Apache Software Foundation. All Rights Reserved.