Package com.adaptris.core

Class PollerImp

java.lang.Object

com.adaptris.core.PollerImp

All Implemented Interfaces:

ComponentLifecycle, Poller

Direct Known Subclasses:

FsImmediateEventPoller, QuartzCronPoller, ScheduledTaskPoller

public abstract class PollerImp
extends java.lang.Object
implements Poller

Partial implementation of Poller.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PollerImp.Callback

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
PollerImp()

Method Summary

Modifier and Type	Method	Description
protected boolean	attemptLock()
protected void	processMessages()	Message processing behaviour, which is common to concrete implementations.
void	registerConsumer(AdaptrisPollingConsumer c)	Register the AdaptrisPollingConsumer to use.
protected void	releaseLock()
AdaptrisPollingConsumer	retrieveConsumer()	Retrieve the AdaptrisPollingConsumer to use.
<T> T	retrieveConsumer(java.lang.Class<T> type)	Return the register consumer with casting.
<T extends Poller> T	withPollerCallback(PollerImp.Callback c)

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.ComponentLifecycle

close, init, start, stop

Field Detail

log

protected transient org.slf4j.Logger log

Constructor Detail

PollerImp

public PollerImp()

Method Detail

attemptLock

protected boolean attemptLock()

releaseLock

protected void releaseLock()

retrieveConsumer

public AdaptrisPollingConsumer retrieveConsumer()

Description copied from interface: Poller

Retrieve the AdaptrisPollingConsumer to use.

Specified by:

retrieveConsumer in interface Poller

Returns:

the AdaptrisPollingConsumer to use

retrieveConsumer

public <T> T retrieveConsumer(java.lang.Class<T> type)

Description copied from interface: Poller

Return the register consumer with casting.

Specified by:

retrieveConsumer in interface Poller

registerConsumer

public void registerConsumer(AdaptrisPollingConsumer c)

Description copied from interface: Poller

Register the AdaptrisPollingConsumer to use.

Specified by:

registerConsumer in interface Poller

Parameters:

c - the AdaptrisPollingConsumer to use

See Also:

(com.adaptris.core.AdaptrisPollingConsumer)

withPollerCallback

public <T extends Poller> T withPollerCallback(PollerImp.Callback c)

processMessages

protected void processMessages()

Message processing behaviour, which is common to concrete implementations. (The difference is how it is triggered.)