public abstract class AmqpLink extends WatchBase
Constructor and Description |
---|
AmqpLink() |
Modifier and Type | Method and Description |
---|---|
protected void |
assertExecuting() |
protected static void |
assertNotOnDispatchQueue() |
protected void |
attach() |
void |
close() |
protected void |
defer(Defer defer) |
protected AmqpConnection |
getConnection() |
protected abstract Endpoint |
getEndpoint() |
protected abstract org.apache.qpid.proton.hawtdispatch.api.AmqpEndpointBase |
getParent() |
Future<ErrorCondition> |
getRemoteCloseFuture() |
ErrorCondition |
getRemoteError() |
Future<Void> |
getRemoteOpenFuture() |
EndpointState |
getRemoteState() |
protected AmqpTransport |
getTransport() |
void |
onRemoteClose(Callback<ErrorCondition> cb) |
void |
onRemoteOpen(Callback<Void> cb) |
protected abstract void |
processDelivery(Delivery delivery) |
protected void |
pumpOut() |
protected org.fusesource.hawtdispatch.DispatchQueue |
queue() |
protected static ErrorCondition |
toError(Throwable value) |
ErrorCondition |
waitForRemoteClose() |
void |
waitForRemoteOpen() |
addWatch, fireWatches
protected abstract void processDelivery(Delivery delivery)
protected abstract Endpoint getEndpoint()
protected abstract org.apache.qpid.proton.hawtdispatch.api.AmqpEndpointBase getParent()
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.