public class AmqpTransport extends WatchBase
Modifier and Type | Field and Description |
---|---|
static EnumSet<EndpointState> |
ALL_SET |
Sasl |
sasl |
Modifier and Type | Method and Description |
---|---|
static AmqpTransport |
accept(org.fusesource.hawtdispatch.transport.Transport transport) |
void |
assertExecuting() |
static AmqpTransport |
connect(AmqpConnectOptions options) |
ProtonJConnection |
connection() |
EndpointContext |
context(Endpoint endpoint) |
void |
defer(Defer defer) |
void |
disconnect() |
void |
fireListenerEvents() |
Throwable |
getFailure() |
AmqpListener |
getListener() |
ProtocolTracer |
getProtocolTracer() |
TransportState |
getState() |
void |
onTransportConnected(Callback<Void> cb) |
void |
onTransportDisconnected(Callback<Void> cb) |
void |
onTransportFailure(Callback<Throwable> cb) |
void |
pumpOut() |
org.fusesource.hawtdispatch.DispatchQueue |
queue() |
void |
setListener(AmqpListener listener) |
void |
setProtocolTracer(ProtocolTracer protocolTracer) |
addWatch, fireWatches
public static final EnumSet<EndpointState> ALL_SET
public Sasl sasl
public static AmqpTransport connect(AmqpConnectOptions options)
public TransportState getState()
public static AmqpTransport accept(org.fusesource.hawtdispatch.transport.Transport transport)
public void defer(Defer defer)
public void pumpOut()
public void fireListenerEvents()
public ProtonJConnection connection()
public AmqpListener getListener()
public void setListener(AmqpListener listener)
public EndpointContext context(Endpoint endpoint)
public void disconnect()
public org.fusesource.hawtdispatch.DispatchQueue queue()
public void assertExecuting()
public Throwable getFailure()
public void setProtocolTracer(ProtocolTracer protocolTracer)
public ProtocolTracer getProtocolTracer()
Copyright © 2016 The Apache Software Foundation. All rights reserved.