com.hazelcast.topic.impl.reliable

Class ReliableMessageListenerAdapter<E>

java.lang.Object

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

All Implemented Interfaces:

MessageListener<E>, ReliableMessageListener<E>, EventListener

public class ReliableMessageListenerAdapter<E>
extends Object
implements ReliableMessageListener<E>

Constructor Summary

Constructors

Constructor and Description
ReliableMessageListenerAdapter(MessageListener<E> messageListener)

Method Summary

Modifier and Type	Method and Description
boolean	isLossTolerant() Checks if this ReliableMessageListener is able to deal with message loss.
boolean	isTerminal(Throwable failure) Checks if the ReliableMessageListener should be terminated based on an exception thrown while calling MessageListener.onMessage(com.hazelcast.core.Message).
void	onMessage(Message<E> message) Invoked when a message is received for the added topic.
long	retrieveInitialSequence() Retrieves the initial sequence from which this ReliableMessageListener should start.
void	storeSequence(long sequence) Informs the ReliableMessageListener that it should store the sequence.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReliableMessageListenerAdapter

public ReliableMessageListenerAdapter(MessageListener<E> messageListener)

Method Detail

retrieveInitialSequence

public long retrieveInitialSequence()

Description copied from interface: ReliableMessageListener

Retrieves the initial sequence from which this ReliableMessageListener should start.

Return -1 if there is no initial sequence and you want to start from the next published message.

If you intend to create a durable subscriber so you continue from where you stopped the previous time, load the previous sequence and add 1. If you don't add one, then you will be receiving the same message twice.

Specified by:

retrieveInitialSequence in interface ReliableMessageListener<E>

Returns:

the initial sequence

storeSequence

public void storeSequence(long sequence)

Description copied from interface: ReliableMessageListener

Informs the ReliableMessageListener that it should store the sequence. This method is called before the message is processed. Can be used to make a durable subscription.

Specified by:

storeSequence in interface ReliableMessageListener<E>

Parameters:

sequence - the sequence

isLossTolerant

public boolean isLossTolerant()

Description copied from interface: ReliableMessageListener

Checks if this ReliableMessageListener is able to deal with message loss. Even though the reliable topic promises to be reliable, it can be that a MessageListener is too slow. Eventually the message won't be available anymore.

If the ReliableMessageListener is not loss tolerant and the topic detects that there are missing messages, it will terminate the ReliableMessageListener.

Specified by:

isLossTolerant in interface ReliableMessageListener<E>

Returns:

true if the ReliableMessageListener is tolerant towards losing messages.

onMessage

public void onMessage(Message<E> message)

Description copied from interface: MessageListener

Invoked when a message is received for the added topic. Note that topic guarantees message ordering. Therefore there is only one thread invoking onMessage. The user should not keep the thread busy, but preferably should dispatch it via an Executor. This will increase the performance of the topic.

Specified by:

onMessage in interface MessageListener<E>

Parameters:

message - the message that is received for the added topic

isTerminal

public boolean isTerminal(Throwable failure)

Description copied from interface: ReliableMessageListener

Checks if the ReliableMessageListener should be terminated based on an exception thrown while calling MessageListener.onMessage(com.hazelcast.core.Message).

Specified by:

isTerminal in interface ReliableMessageListener<E>

Parameters:

failure - the exception thrown while calling MessageListener.onMessage(com.hazelcast.core.Message).

Returns:

true if the ReliableMessageListener should terminate itself, false if it should keep on running.

toString

public String toString()

Overrides:

toString in class Object