com.hazelcast.topic.impl.reliable

Class MessageRunner<E>

java.lang.Object

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

All Implemented Interfaces:

ExecutionCallback<ReadResultSet<ReliableTopicMessage>>

Direct Known Subclasses:

ClientReliableMessageRunner, ReliableMessageRunner

public abstract class MessageRunner<E>
extends Object
implements ExecutionCallback<ReadResultSet<ReliableTopicMessage>>

An ExecutionCallback that will try to read an item from the ringbuffer or blocks if no item is available. All data that are read is pushed into the MessageListener. It is a self-perpetuating stream of async calls.

The runner keeps track of the sequence.

Field Summary

Fields

Modifier and Type	Field and Description
protected ReliableMessageListener<E>	listener
protected ILogger	logger
protected Ringbuffer<ReliableTopicMessage>	ringbuffer
protected long	sequence
protected String	topicName

Constructor Summary

Constructors

Constructor and Description
MessageRunner(String id, ReliableMessageListener<E> listener, Ringbuffer<ReliableTopicMessage> ringbuffer, String topicName, int batchSze, SerializationService serializationService, Executor executor, ConcurrentMap<String,MessageRunner<E>> runnersMap, ILogger logger)

Method Summary

Modifier and Type	Method and Description
protected abstract Throwable	adjustThrowable(Throwable t) Needed because client / server behaviour is different on onFailure call
void	cancel()
protected abstract long	getHeadSequence(StaleSequenceException staleSequenceException)
protected abstract Member	getMember(ReliableTopicMessage m)
protected boolean	handleInternalException(Throwable t)
boolean	isCancelled()
void	next()
void	onFailure(Throwable t) Called when an execution is completed with an error.
void	onResponse(ReadResultSet<ReliableTopicMessage> result) Called when an execution is completed successfully.
protected abstract void	updateStatistics()

Methods inherited from class java.lang.Object

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

Field Detail

ringbuffer

protected final Ringbuffer<ReliableTopicMessage> ringbuffer

logger

protected final ILogger logger

listener

protected final ReliableMessageListener<E> listener

topicName

protected final String topicName

sequence

protected long sequence

Constructor Detail

MessageRunner

public MessageRunner(String id,
                     ReliableMessageListener<E> listener,
                     Ringbuffer<ReliableTopicMessage> ringbuffer,
                     String topicName,
                     int batchSze,
                     SerializationService serializationService,
                     Executor executor,
                     ConcurrentMap<String,MessageRunner<E>> runnersMap,
                     ILogger logger)

Method Detail

next

public void next()

onResponse

public void onResponse(ReadResultSet<ReliableTopicMessage> result)

Description copied from interface: ExecutionCallback

Called when an execution is completed successfully.

Specified by:

onResponse in interface ExecutionCallback<ReadResultSet<ReliableTopicMessage>>

Parameters:

result - the result of the successful execution

updateStatistics

protected abstract void updateStatistics()

getMember

protected abstract Member getMember(ReliableTopicMessage m)

onFailure

public void onFailure(Throwable t)

Description copied from interface: ExecutionCallback

Called when an execution is completed with an error.

Specified by:

onFailure in interface ExecutionCallback<ReadResultSet<ReliableTopicMessage>>

Parameters:

t - the exception that is thrown

handleInternalException

protected boolean handleInternalException(Throwable t)

Parameters:

t - throwable to check if it is terminal or can be handled so that topic can continue

Returns:

true if the exception was handled and the listener may continue reading

adjustThrowable

protected abstract Throwable adjustThrowable(Throwable t)

Needed because client / server behaviour is different on onFailure call

Parameters:

t - throwable

Returns:

adjusted throwable

getHeadSequence

protected abstract long getHeadSequence(StaleSequenceException staleSequenceException)

cancel

public void cancel()

isCancelled

public boolean isCancelled()