public class AmqpReceiver extends AmqpLink
Constructor and Description |
---|
AmqpReceiver(AmqpSession parent,
Receiver receiver2,
QoS qos) |
addWatch, fireWatches
public AmqpReceiver(AmqpSession parent, Receiver receiver2, QoS qos)
protected Receiver getEndpoint()
protected AmqpSession getParent()
protected void processDelivery(Delivery delivery)
processDelivery
in class AmqpLink
protected void onMessage(Delivery delivery, org.fusesource.hawtbuf.Buffer buffer)
public void drain()
public void resume()
public void suspend()
public AmqpDeliveryListener getDeliveryListener()
public void setDeliveryListener(AmqpDeliveryListener deliveryListener)
protected AmqpConnection getConnection()
protected AmqpTransport getTransport()
protected org.fusesource.hawtdispatch.DispatchQueue queue()
protected void assertExecuting()
public ErrorCondition waitForRemoteClose() throws Exception
Exception
public Future<ErrorCondition> getRemoteCloseFuture()
public void onRemoteClose(Callback<ErrorCondition> cb)
public void close()
public EndpointState getRemoteState()
public ErrorCondition getRemoteError()
protected static ErrorCondition toError(Throwable value)
protected void attach()
protected void defer(Defer defer)
protected void pumpOut()
protected static void assertNotOnDispatchQueue()
Copyright © 2016 The Apache Software Foundation. All rights reserved.