public interface AmqpReceiver extends ReadStream<AmqpMessage>
Modifier and Type | Method and Description |
---|---|
String |
address()
The listened address.
|
void |
close(Handler<AsyncResult<Void>> handler)
Closes the receiver.
|
AmqpConnection |
connection()
Gets the connection having created the receiver.
|
endHandler, exceptionHandler, fetch, handler, pause, pipe, pipeTo, pipeTo, resume
String address()
null
void close(Handler<AsyncResult<Void>> handler)
handler
- handler called when the receiver has been closed, can be null
AmqpConnection connection()
null
Copyright © 2019 Eclipse. All rights reserved.