public class AmqpListener extends Object
Constructor and Description |
---|
AmqpListener() |
Modifier and Type | Method and Description |
---|---|
void |
processDelivery(Delivery delivery) |
void |
processFailure(Throwable e) |
void |
processRefill() |
void |
processRemoteClose(Endpoint endpoint,
org.fusesource.hawtdispatch.Task onComplete) |
void |
processRemoteOpen(Endpoint endpoint,
org.fusesource.hawtdispatch.Task onComplete) |
Sasl |
processSaslConnect(ProtonJTransport protonTransport) |
Sasl |
processSaslEvent(Sasl sasl) |
void |
processTransportConnected() |
void |
processTransportFailure(IOException e) |
public Sasl processSaslConnect(ProtonJTransport protonTransport)
public void processRemoteOpen(Endpoint endpoint, org.fusesource.hawtdispatch.Task onComplete)
public void processRemoteClose(Endpoint endpoint, org.fusesource.hawtdispatch.Task onComplete)
public void processDelivery(Delivery delivery)
public void processTransportConnected()
public void processTransportFailure(IOException e)
public void processFailure(Throwable e)
public void processRefill()
Copyright © 2016 The Apache Software Foundation. All rights reserved.