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.

Version:
$Revision$

Field Summary
static long MAX_TIMEOUT
           
 
Constructor Summary
BlockingQueueTransport(edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue channel)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue getQueue()
           
 java.lang.String getRemoteAddress()
           
 void oneway(java.lang.Object command)
          A one way asynchronous send
 
Methods inherited from class org.apache.activemq.transport.TransportSupport
asyncRequest, checkStarted, doConsume, getTransportListener, narrow, onException, request, request, setTransportListener
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
dispose, isStarted, isStopped, isStopping, 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(edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue channel)
Method Detail

getQueue

public edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue getQueue()

oneway

public void oneway(java.lang.Object command)
            throws java.io.IOException
Description copied from interface: Transport
A one way asynchronous send

Throws:
java.io.IOException

getRemoteAddress

public java.lang.String getRemoteAddress()
Returns:
the remote address for this connection

doStart

protected void doStart()
                throws java.lang.Exception
Specified by:
doStart in class ServiceSupport
Throws:
java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception
Specified by:
doStop in class ServiceSupport
Throws:
java.lang.Exception


Copyright © 2011 Apache Software Foundation. All Rights Reserved.