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> T |
retrieveConsumer(java.lang.Class<T> type)
Return the register consumer with casting.
|
<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 usepublic <T> T retrieveConsumer(java.lang.Class<T> type)
Poller
retrieveConsumer
in interface Poller
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.)