public interface AmqpReceiver extends io.vertx.core.streams.ReadStream<AmqpMessage>
Modifier and Type | Method and Description |
---|---|
String |
address()
The listened address.
|
io.vertx.core.Future<Void> |
close()
Like
close(Handler) but returns a Future of the asynchronous result |
void |
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
Closes the receiver.
|
AmqpConnection |
connection()
Gets the connection having created the receiver.
|
AmqpReceiver |
endHandler(io.vertx.core.Handler<Void> endHandler) |
AmqpReceiver |
exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
AmqpReceiver |
fetch(long amount) |
AmqpReceiver |
handler(io.vertx.core.Handler<AmqpMessage> handler) |
AmqpReceiver |
pause() |
AmqpReceiver |
resume() |
AmqpReceiver exceptionHandler(io.vertx.core.Handler<Throwable> handler)
exceptionHandler
in interface io.vertx.core.streams.ReadStream<AmqpMessage>
exceptionHandler
in interface io.vertx.core.streams.StreamBase
AmqpReceiver handler(io.vertx.core.Handler<AmqpMessage> handler)
handler
in interface io.vertx.core.streams.ReadStream<AmqpMessage>
AmqpReceiver pause()
pause
in interface io.vertx.core.streams.ReadStream<AmqpMessage>
AmqpReceiver resume()
resume
in interface io.vertx.core.streams.ReadStream<AmqpMessage>
AmqpReceiver fetch(long amount)
fetch
in interface io.vertx.core.streams.ReadStream<AmqpMessage>
AmqpReceiver endHandler(io.vertx.core.Handler<Void> endHandler)
endHandler
in interface io.vertx.core.streams.ReadStream<AmqpMessage>
String address()
null
void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
handler
- handler called when the receiver has been closed, can be null
io.vertx.core.Future<Void> close()
close(Handler)
but returns a Future
of the asynchronous resultAmqpConnection connection()
null
Copyright © 2021 Eclipse. All rights reserved.