- All Superinterfaces:
- LifecycleAware, NamedComponent, Source
- All Known Implementing Classes:
- AbstractPollableSource, JMSSource, KafkaSource, SequenceGeneratorSource, StressSource
public interface PollableSource
- extends Source
Source that requires an external driver to poll to determine
whether there are events that are available to ingest
from the source.
- See Also:
Attempt to pull an item from the source, sending it to the channel.
When driven by an
EventDrivenSourceRunner process is guaranteed
to be called only by a single thread at a time, with no concurrency.
Any other mechanism driving a pollable source must follow the same
READY if one or more events were created from the source.
BACKOFF if no events could be created from the source.
EventDeliveryException - If there was a failure in delivering to
the attached channel, or if a failure occurred in acquiring data from
Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.