public class AmqpConnection extends WatchBase
addWatch, fireWatches
public static AmqpConnection connect(AmqpConnectOptions options)
protected Endpoint getEndpoint()
protected AmqpConnection getConnection()
protected org.apache.qpid.proton.hawtdispatch.api.AmqpEndpointBase getParent()
public AmqpSession createSession()
public int getMaxSessions()
public void disconnect()
public TransportState getTransportState()
public Throwable getTransportFailure()
public org.fusesource.hawtdispatch.DispatchQueue queue()
public void setProtocolTracer(ProtocolTracer protocolTracer)
public ProtocolTracer getProtocolTracer()
public void close()
protected AmqpTransport getTransport()
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.