com.adaptris.core.interceptor

Class NotifyingInterceptorByCount

java.lang.Object

com.adaptris.core.interceptor.WorkflowInterceptorImpl

com.adaptris.core.interceptor.NotifyingInterceptor

com.adaptris.core.interceptor.NotifyingInterceptorByCount

All Implemented Interfaces:

AdaptrisComponent, ComponentLifecycle, ComponentLifecycleExtension, StateManagedComponent, WorkflowInterceptor

Direct Known Subclasses:

MessageCountNotification, MessageThresholdNotification

public abstract class NotifyingInterceptorByCount
extends NotifyingInterceptor

Since:

3.0.4

Nested Class Summary

Nested classes/interfaces inherited from class com.adaptris.core.interceptor.WorkflowInterceptorImpl

WorkflowInterceptorImpl.WorkflowInterceptorException

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	KEY_MESSAGE_COUNT Key within the properties containing the total message count
static java.lang.String	KEY_MESSAGE_ERROR Key within the properties containing the total number of errors.
static java.lang.String	KEY_MESSAGE_SIZE Key within the properties containing the total size of errors.
static java.lang.String	KEY_TIMESLICE_END Key within the properties containing the end time for the timeslice.
static java.lang.String	KEY_TIMESLICE_START Key within the properties containing the end time for the timeslice.

Fields inherited from class com.adaptris.core.interceptor.WorkflowInterceptorImpl

log

Constructor Summary

Constructors

Constructor and Description
NotifyingInterceptorByCount()

Method Summary

Modifier and Type	Method and Description
protected static java.util.Properties	asProperties(MessageStatistic stat)
protected MessageStatistic	getAndIncrementStatistic(AdaptrisMessage inputMsg, AdaptrisMessage outputMsg)
protected MessageStatistic	getCurrentTimeSlice()
TimeInterval	getTimesliceDuration()
void	setTimesliceDuration(TimeInterval timesliceDuration) Set the duration of each timeslice for gathering.

Methods inherited from class com.adaptris.core.interceptor.WorkflowInterceptorImpl

changeState, getUniqueId, parentChannel, parentWorkflow, prepare, registerParentChannel, registerParentWorkflow, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, setUniqueId, wasSuccessful

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.WorkflowInterceptor

processingStart, workflowEnd, workflowStart

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init, start, stop

Field Detail

KEY_MESSAGE_COUNT

public static final java.lang.String KEY_MESSAGE_COUNT

Key within the properties containing the total message count

See Also:

Constant Field Values

KEY_MESSAGE_ERROR

public static final java.lang.String KEY_MESSAGE_ERROR

Key within the properties containing the total number of errors.

See Also:

Constant Field Values

KEY_MESSAGE_SIZE

public static final java.lang.String KEY_MESSAGE_SIZE

Key within the properties containing the total size of errors.

See Also:

Constant Field Values

KEY_TIMESLICE_END

public static final java.lang.String KEY_TIMESLICE_END

Key within the properties containing the end time for the timeslice.

See Also:

Constant Field Values

KEY_TIMESLICE_START

public static final java.lang.String KEY_TIMESLICE_START

Key within the properties containing the end time for the timeslice.

See Also:

Constant Field Values

Constructor Detail

NotifyingInterceptorByCount

public NotifyingInterceptorByCount()

Method Detail

getCurrentTimeSlice

protected MessageStatistic getCurrentTimeSlice()

asProperties

protected static java.util.Properties asProperties(MessageStatistic stat)

getAndIncrementStatistic

protected MessageStatistic getAndIncrementStatistic(AdaptrisMessage inputMsg,
                                                    AdaptrisMessage outputMsg)

getTimesliceDuration

public TimeInterval getTimesliceDuration()

setTimesliceDuration

public void setTimesliceDuration(TimeInterval timesliceDuration)

Set the duration of each timeslice for gathering.

Parameters:

timesliceDuration - the timeslice duration, default is 1 minute if not explicitly specified.