public class SequenceGeneratorSource extends AbstractSource implements PollableSource, Configurable
PollableSource.Status
Constructor and Description |
---|
SequenceGeneratorSource() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Context context)
Read parameters from context
batchSize = type int that defines the size of event batches
|
PollableSource.Status |
process()
Attempt to pull an item from the source, sending it to the channel.
|
void |
start()
Starts a service or component.
|
void |
stop()
Stops a service or component.
|
getChannelProcessor, getLifecycleState, getName, setChannelProcessor, setName, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getChannelProcessor, setChannelProcessor
getLifecycleState
getName, setName
public void configure(Context context)
configure
in interface Configurable
public PollableSource.Status process() throws EventDeliveryException
PollableSource
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
semantics.
process
in interface PollableSource
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
the source.public void start()
LifecycleAware
Starts a service or component.
Implementations should determine the result of any start logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
start
in interface LifecycleAware
start
in class AbstractSource
public void stop()
LifecycleAware
Stops a service or component.
Implementations should determine the result of any stop logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
stop
in interface LifecycleAware
stop
in class AbstractSource
Copyright © 2009-2014 Apache Software Foundation. All Rights Reserved.