org.apache.flume.source.jms

Class JMSSource

java.lang.Object

org.apache.flume.source.BasicSourceSemantics

org.apache.flume.source.AbstractPollableSource

org.apache.flume.source.jms.JMSSource

All Implemented Interfaces:

BatchSizeSupported, Configurable, LifecycleAware, NamedComponent, PollableSource, Source

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public class JMSSource
extends AbstractPollableSource
implements BatchSizeSupported

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flume.PollableSource

PollableSource.Status

Field Summary

Fields

Modifier and Type	Field and Description
static String	JNDI_ALLOWED_PROTOCOLS

Constructor Summary

Constructors

Constructor and Description
JMSSource()
JMSSource(InitialContextFactory initialContextFactory)

Method Summary

Modifier and Type	Method and Description
protected void	doConfigure(Context context)
protected PollableSource.Status	doProcess()
protected void	doStart()
protected void	doStop()
long	getBatchSize() Returns the batch size
static void	verifyContext(String location)

Methods inherited from class org.apache.flume.source.AbstractPollableSource

configure, getBackOffSleepIncrement, getMaxBackOffSleepInterval, process

Methods inherited from class org.apache.flume.source.BasicSourceSemantics

getChannelProcessor, getLifecycleState, getName, getStartException, isStarted, setChannelProcessor, setLifecycleState, setName, start, stop, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flume.Source

getChannelProcessor, setChannelProcessor

Methods inherited from interface org.apache.flume.lifecycle.LifecycleAware

getLifecycleState, start, stop

Methods inherited from interface org.apache.flume.NamedComponent

getName, setName

Field Detail

JNDI_ALLOWED_PROTOCOLS

public static final String JNDI_ALLOWED_PROTOCOLS

See Also:

Constant Field Values

Constructor Detail

JMSSource

public JMSSource()

JMSSource

public JMSSource(InitialContextFactory initialContextFactory)

Method Detail

verifyContext

public static void verifyContext(String location)

doConfigure

protected void doConfigure(Context context)
                    throws FlumeException

Specified by:

doConfigure in class BasicSourceSemantics

Throws:

FlumeException

doProcess

protected PollableSource.Status doProcess()
                                   throws EventDeliveryException

Specified by:

doProcess in class AbstractPollableSource

Throws:

EventDeliveryException

doStart

protected void doStart()

Specified by:

doStart in class BasicSourceSemantics

doStop

protected void doStop()

Specified by:

doStop in class BasicSourceSemantics

getBatchSize

public long getBatchSize()

Description copied from interface: BatchSizeSupported

Returns the batch size

Specified by:

getBatchSize in interface BatchSizeSupported