public abstract class PollerImp extends java.lang.Object implements Poller
Partial implementation of Poller
.
Modifier and Type | Class and Description |
---|---|
static interface |
PollerImp.Callback |
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
Constructor and Description |
---|
PollerImp() |
Modifier and Type | Method and 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 extends Poller> |
withPollerCallback(PollerImp.Callback c) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, init, start, stop
protected boolean attemptLock()
protected void releaseLock()
public AdaptrisPollingConsumer retrieveConsumer()
Poller
Retrieve the AdaptrisPollingConsumer
to use.
retrieveConsumer
in interface Poller
AdaptrisPollingConsumer
to usePoller.retrieveConsumer()
public void registerConsumer(AdaptrisPollingConsumer c)
Poller
Register the AdaptrisPollingConsumer
to use.
registerConsumer
in interface Poller
c
- the AdaptrisPollingConsumer
to use(com.adaptris.core.AdaptrisPollingConsumer)
public <T extends Poller> T withPollerCallback(PollerImp.Callback c)
protected void processMessages()
Message processing behaviour, which is common to concrete implementations. (The difference is how it is triggered.)