public class BlockingQueueTransport extends org.apache.activemq.transport.TransportSupport
Queue
so that they can be dispatched
by the HTTP GET requests from the client.Modifier and Type | Field and Description |
---|---|
static long |
MAX_TIMEOUT |
Constructor and Description |
---|
BlockingQueueTransport(BlockingQueue<Object> channel) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop(org.apache.activemq.util.ServiceStopper stopper) |
BlockingQueue<Object> |
getQueue() |
int |
getReceiveCounter() |
String |
getRemoteAddress() |
void |
oneway(Object command) |
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
public static final long MAX_TIMEOUT
public BlockingQueueTransport(BlockingQueue<Object> channel)
public BlockingQueue<Object> getQueue()
public void oneway(Object command) throws IOException
IOException
public String getRemoteAddress()
protected void doStart() throws Exception
doStart
in class org.apache.activemq.util.ServiceSupport
Exception
protected void doStop(org.apache.activemq.util.ServiceStopper stopper) throws Exception
doStop
in class org.apache.activemq.util.ServiceSupport
Exception
public int getReceiveCounter()
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.