public class AmqpSender extends AmqpLink
Constructor and Description |
---|
AmqpSender(AmqpSession parent,
Sender sender2,
QoS qos) |
addWatch, fireWatches
public AmqpSender(AmqpSession parent, Sender sender2, QoS qos)
public void close()
protected Sender getEndpoint()
protected AmqpSession getParent()
public MessageDelivery send(Message message)
public long getOverflowBufferSize()
protected void pumpDeliveries()
protected void processDelivery(Delivery delivery)
processDelivery
in class AmqpLink
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 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.