com.hazelcast.topic.impl.reliable

Class ReliableMessageRunner<E>

java.lang.Object

com.hazelcast.topic.impl.reliable.MessageRunner<E>

com.hazelcast.topic.impl.reliable.ReliableMessageRunner<E>

All Implemented Interfaces:

ExecutionCallback<ReadResultSet<ReliableTopicMessage>>

public class ReliableMessageRunner<E>
extends MessageRunner<E>

Field Summary

Fields inherited from class com.hazelcast.topic.impl.reliable.MessageRunner

listener, logger, ringbuffer, sequence, topicName

Method Summary

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()

Methods inherited from class com.hazelcast.topic.impl.reliable.MessageRunner

cancel, handleInternalException, isCancelled, next, onFailure, onResponse

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

updateStatistics

protected void updateStatistics()

Specified by:

updateStatistics in class MessageRunner<E>

getMember

protected Member getMember(ReliableTopicMessage m)

Specified by:

getMember in class MessageRunner<E>

adjustThrowable

protected Throwable adjustThrowable(Throwable t)

Description copied from class: MessageRunner

Needed because client / server behaviour is different on onFailure call

Specified by:

adjustThrowable in class MessageRunner<E>

Parameters:

t - throwable

Returns:

adjusted throwable

getHeadSequence

protected long getHeadSequence(StaleSequenceException staleSequenceException)

Specified by:

getHeadSequence in class MessageRunner<E>