public class AmqpSession extends WatchBase
Constructor and Description |
---|
AmqpSession(AmqpConnection parent,
ProtonJSession session) |
addWatch, fireWatches
public AmqpSession(AmqpConnection parent, ProtonJSession session)
protected Endpoint getEndpoint()
protected AmqpConnection getParent()
public AmqpSender createSender(Target target)
public AmqpSender createSender(Target target, QoS qos)
public AmqpSender createSender(Target target, QoS qos, String name)
public AmqpReceiver createReceiver(Source source)
public AmqpReceiver createReceiver(Source source, QoS qos)
public AmqpReceiver createReceiver(Source source, QoS qos, int prefetch)
public AmqpReceiver createReceiver(Source source, QoS qos, int prefetch, String name)
public Message createBinaryMessage(byte[] value)
public Message createBinaryMessage(byte[] value, int offset, int len)
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.