com.adaptris.core.services

Class MessageCountRestartStrategy

java.lang.Object

com.adaptris.core.services.MessageCountRestartStrategy

All Implemented Interfaces:

RestartStrategy

public class MessageCountRestartStrategy
extends java.lang.Object
implements RestartStrategy

This RestartStrategy monitors the number of messages processed and if this number passes our maximum threshold, then this strategy will return true upon requiresRestart(). Finally upon calling requiresRestart, should we return true, we will also reset the internal number of messages processed count back down to zero.

The default max-messages-count is set to 50.

In the adapter configuration file this class is aliased as message-count-restart-strategy which is the preferred alternative to the fully qualified classname when building your configuration.

Constructor Summary

Constructors

Constructor and Description
MessageCountRestartStrategy()

Method Summary

Modifier and Type	Method and Description
int	getMaxMessagesCount()
void	messageProcessed(AdaptrisMessage msg) Mark the current message as processed.
boolean	requiresRestart() Whether or not a restart of the underlying service is required.
void	setMaxMessagesCount(int maxMessagesCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageCountRestartStrategy

public MessageCountRestartStrategy()

Method Detail

messageProcessed

public void messageProcessed(AdaptrisMessage msg)

Description copied from interface: RestartStrategy

Mark the current message as processed.

Specified by:

messageProcessed in interface RestartStrategy

Parameters:

msg - the message currently being processed.

requiresRestart

public boolean requiresRestart()

Description copied from interface: RestartStrategy

Whether or not a restart of the underlying service is required.

Specified by:

requiresRestart in interface RestartStrategy

Returns:

true if a restart is required.

getMaxMessagesCount

public int getMaxMessagesCount()

setMaxMessagesCount

public void setMaxMessagesCount(int maxMessagesCount)