public class MessageConsumerImpl<T> extends HandlerRegistration<T> implements MessageConsumer<T>
bus, src| Modifier and Type | Method and Description |
|---|---|
String |
address() |
ReadStream<T> |
bodyStream() |
void |
completionHandler(Handler<AsyncResult<Void>> handler)
Optional method which can be called to indicate when the registration has been propagated across the cluster.
|
void |
discardHandler(Handler<Message<T>> handler) |
protected void |
dispatch(Message<T> msg,
ContextInternal context,
Handler<Message<T>> handler) |
protected boolean |
doReceive(Message<T> message) |
MessageConsumer<T> |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
MessageConsumer<T> |
exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
MessageConsumer<T> |
fetch(long amount)
Fetch the specified
amount of elements. |
Handler<Message<T>> |
getHandler() |
int |
getMaxBufferedMessages() |
MessageConsumer<T> |
handler(Handler<Message<T>> h)
Set a data handler.
|
MessageConsumer<T> |
pause()
Pause the
ReadStream, it sets the buffer in fetch mode and clears the actual demand. |
MessageConsumer<T> |
resume()
Resume reading, and sets the buffer in
flowing mode. |
MessageConsumer<T> |
setMaxBufferedMessages(int maxBufferedMessages)
Set the number of messages this registration will buffer when this stream is paused.
|
Future<Void> |
unregister()
Unregisters the handler which created this registration
|
close, isRegistered, unregisterclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitisRegistered, unregisterpipe, pipeTo, pipeTopublic MessageConsumer<T> setMaxBufferedMessages(int maxBufferedMessages)
MessageConsumer1000.
When a new value is set, buffered messages may be discarded to reach the new value. The most recent messages will be kept.
setMaxBufferedMessages in interface MessageConsumer<T>maxBufferedMessages - the maximum number of messages that can be bufferedpublic int getMaxBufferedMessages()
getMaxBufferedMessages in interface MessageConsumer<T>public String address()
address in interface MessageConsumer<T>public void completionHandler(Handler<AsyncResult<Void>> handler)
MessageConsumercompletionHandler in interface MessageConsumer<T>handler - the completion handlerpublic Future<Void> unregister()
MessageConsumerunregister in interface MessageConsumer<T>unregister in class HandlerRegistration<T>protected boolean doReceive(Message<T> message)
doReceive in class HandlerRegistration<T>protected void dispatch(Message<T> msg, ContextInternal context, Handler<Message<T>> handler)
dispatch in class HandlerRegistration<T>public MessageConsumer<T> handler(Handler<Message<T>> h)
ReadStreamhandler in interface MessageConsumer<T>handler in interface ReadStream<Message<T>>public ReadStream<T> bodyStream()
bodyStream in interface MessageConsumer<T>public MessageConsumer<T> 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 MessageConsumer<T>pause in interface ReadStream<Message<T>>public MessageConsumer<T> resume()
ReadStreamflowing mode.
If the ReadStream has been paused, reading will recommence on it.resume in interface MessageConsumer<T>resume in interface ReadStream<Message<T>>public MessageConsumer<T> 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 MessageConsumer<T>fetch in interface ReadStream<Message<T>>public MessageConsumer<T> endHandler(Handler<Void> endHandler)
ReadStreamendHandler in interface MessageConsumer<T>endHandler in interface ReadStream<Message<T>>public MessageConsumer<T> exceptionHandler(Handler<Throwable> handler)
ReadStreamexceptionHandler in interface MessageConsumer<T>exceptionHandler in interface ReadStream<Message<T>>exceptionHandler in interface StreamBasehandler - the exception handlerCopyright © 2021. All rights reserved.