public class AmqpReceiverImpl extends Object implements AmqpReceiver
| 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.
|
AmqpReceiverImpl |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
AmqpReceiver |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
AmqpReceiverImpl |
fetch(long amount)
Fetch the specified
amount of elements. |
AmqpReceiver |
handler(Handler<AmqpMessage> handler)
Set a data handler.
|
AmqpReceiverImpl |
pause()
Pause the
ReadStream, it sets the buffer in fetch mode and clears the actual demand. |
AmqpReceiverImpl |
resume()
Resume reading, and sets the buffer in
flowing mode. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpipe, pipeTo, pipeTopublic AmqpReceiver exceptionHandler(Handler<Throwable> handler)
ReadStreamexceptionHandler in interface AmqpReceiverexceptionHandler in interface ReadStream<AmqpMessage>exceptionHandler in interface StreamBasehandler - the exception handlerpublic AmqpReceiver handler(Handler<AmqpMessage> handler)
ReadStreamhandler in interface AmqpReceiverhandler in interface ReadStream<AmqpMessage>public AmqpReceiverImpl pause()
ReadStreamReadStream, it sets the buffer in fetch mode and clears the actual demand.
While it's paused, no data will be sent to the data handler.
pause in interface AmqpReceiverpause in interface ReadStream<AmqpMessage>public AmqpReceiverImpl fetch(long amount)
ReadStreamamount of elements. If the ReadStream has been paused, reading will
recommence with the specified amount of items, otherwise the specified amount will
be added to the current stream demand.fetch in interface AmqpReceiverfetch in interface ReadStream<AmqpMessage>public AmqpReceiverImpl resume()
ReadStreamflowing mode.
If the ReadStream has been paused, reading will recommence on it.resume in interface AmqpReceiverresume in interface ReadStream<AmqpMessage>public AmqpReceiverImpl endHandler(Handler<Void> endHandler)
ReadStreamendHandler in interface AmqpReceiverendHandler in interface ReadStream<AmqpMessage>public String address()
AmqpReceiveraddress in interface AmqpReceivernullpublic AmqpConnection connection()
AmqpReceivernullconnection in interface AmqpReceiverpublic void close(Handler<AsyncResult<Void>> handler)
AmqpReceiverclose in interface AmqpReceiverhandler - handler called when the receiver has been closed, can be nullCopyright © 2020. All rights reserved.