org.apache.brooklyn.core.feed

Class Poller<V>

java.lang.Object

org.apache.brooklyn.core.feed.Poller<V>

public class Poller<V>
extends java.lang.Object

For executing periodic polls. Jobs are added to the schedule, and then the poller is started. The jobs will then be executed periodically, and the handler called for the result/failure. Assumes the schedule+start will be done single threaded, and that stop will not be done concurrently.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
Poller(Entity entity, AbstractFeed feed, boolean onlyIfServiceUp)
Poller(Entity entity, boolean onlyIfServiceUp) Deprecated. since 0.12.0 pass in feed

Method Summary

Modifier and Type	Method and Description
boolean	isRunning()
void	scheduleAtFixedRate(java.util.concurrent.Callable<V> job, PollHandler<? super V> handler, Duration period)
void	scheduleAtFixedRate(java.util.concurrent.Callable<V> job, PollHandler<? super V> handler, long period)
void	start()
void	stop()
void	submit(java.util.concurrent.Callable<?> job) Submits a one-off poll job; recommended that callers supply to-String so that task has a decent description
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

log

public static final org.slf4j.Logger log

Constructor Detail

Poller

@Deprecated
public Poller(Entity entity,
                          boolean onlyIfServiceUp)

Deprecated. since 0.12.0 pass in feed

Poller

public Poller(Entity entity,
              AbstractFeed feed,
              boolean onlyIfServiceUp)

Method Detail

submit

public void submit(java.util.concurrent.Callable<?> job)

Submits a one-off poll job; recommended that callers supply to-String so that task has a decent description

scheduleAtFixedRate

public void scheduleAtFixedRate(java.util.concurrent.Callable<V> job,
                                PollHandler<? super V> handler,
                                long period)

scheduleAtFixedRate

public void scheduleAtFixedRate(java.util.concurrent.Callable<V> job,
                                PollHandler<? super V> handler,
                                Duration period)

start

public void start()

stop

public void stop()

isRunning

public boolean isRunning()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object