E
- message typepublic class ClientReliableMessageRunner<E> extends MessageRunner<E>
MessageRunner
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 boolean |
handleInternalException(Throwable t) |
protected void |
updateStatistics() |
cancel, isCancelled, next, onFailure, onResponse
protected void updateStatistics()
updateStatistics
in class MessageRunner<E>
protected Member getMember(ReliableTopicMessage m)
getMember
in class MessageRunner<E>
protected boolean handleInternalException(Throwable t)
handleInternalException
in class MessageRunner<E>
t
- throwable to check if it is terminal or can be handled so that topic can continueprotected Throwable adjustThrowable(Throwable t)
MessageRunner
adjustThrowable
in class MessageRunner<E>
t
- throwableprotected long getHeadSequence(StaleSequenceException staleSequenceException)
getHeadSequence
in class MessageRunner<E>
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.