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$
Constructor Summary |
BlockingQueueTransport(edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue channel)
|
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(edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue channel)
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.