Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.source | |
org.apache.flume.source.jms |
Modifier and Type | Method and Description |
---|---|
PollableSource.Status |
PollableSource.process()
Attempt to pull an item from the source, sending it to the channel.
|
static PollableSource.Status |
PollableSource.Status.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static PollableSource.Status[] |
PollableSource.Status.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
protected abstract PollableSource.Status |
AbstractPollableSource.doProcess() |
PollableSource.Status |
StressSource.process() |
PollableSource.Status |
SequenceGeneratorSource.process() |
PollableSource.Status |
AbstractPollableSource.process() |
Modifier and Type | Method and Description |
---|---|
protected PollableSource.Status |
JMSSource.doProcess() |
Copyright © 2009-2014 Apache Software Foundation. All Rights Reserved.