public class ReliableMessageRunner<E> extends MessageRunner<E>
listener, logger, ringbuffer, sequence, topicName
Modifier and Type | Method and Description |
---|---|
protected Throwable |
adjustThrowable(Throwable t)
Needed because client / server behaviour is different on onFailure call
|
protected long |
getHeadSequence(StaleSequenceException staleSequenceException) |
protected Member |
getMember(ReliableTopicMessage m) |
protected void |
updateStatistics() |
cancel, handleInternalException, isCancelled, next, onFailure, onResponse
protected void updateStatistics()
updateStatistics
in class MessageRunner<E>
protected Member getMember(ReliableTopicMessage m)
getMember
in class MessageRunner<E>
protected Throwable adjustThrowable(Throwable t)
MessageRunner
adjustThrowable
in class MessageRunner<E>
t
- throwableprotected long getHeadSequence(StaleSequenceException staleSequenceException)
getHeadSequence
in class MessageRunner<E>
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.