org.openhubframework.openhub.component.funnel

Class MsgFunnelEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.openhubframework.openhub.component.funnel.MsgFunnelEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class MsgFunnelEndpoint
extends org.apache.camel.impl.DefaultEndpoint

Endpoint for msg-funnel component.

Author:

Petr Juza

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_IDLE_INTERVAL

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
MsgFunnelEndpoint(String endpointUri, org.apache.camel.Component component) Creates new endpoint.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
String	getId() Gets funnel component identifier.
int	getIdleInterval() Gets interval (in seconds) that determines how long can be message processing.
boolean	isExcludeFailedState()
boolean	isGuaranteedOrder() Gets true if funnel component should guaranteed order of processing messages.
boolean	isSingleton()
void	setExcludeFailedState(boolean excludeFailedState) Sets flag whether you want to exclude FAILED state from searching messages for guaranteed order.
void	setGuaranteedOrder(boolean guaranteedOrder)
void	setId(String id)
void	setIdleInterval(int idleInterval)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Field Detail

DEFAULT_IDLE_INTERVAL

public static final int DEFAULT_IDLE_INTERVAL

See Also:

Constant Field Values

Constructor Detail

MsgFunnelEndpoint

public MsgFunnelEndpoint(String endpointUri,
                 org.apache.camel.Component component)

Creates new endpoint.

Parameters:

endpointUri - the URI

component - the "msg-funnel" component

Method Detail

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Throws:

Exception

isSingleton

public boolean isSingleton()

getIdleInterval

public int getIdleInterval()

Gets interval (in seconds) that determines how long can be message processing.

Returns:

interval

setIdleInterval

public void setIdleInterval(int idleInterval)

isGuaranteedOrder

public boolean isGuaranteedOrder()

Gets true if funnel component should guaranteed order of processing messages.

Returns:

true if funnel component should guaranteed order of processing messages otherwise false

setGuaranteedOrder

public void setGuaranteedOrder(boolean guaranteedOrder)

isExcludeFailedState

public boolean isExcludeFailedState()

setExcludeFailedState

public void setExcludeFailedState(boolean excludeFailedState)

Sets flag whether you want to exclude FAILED state from searching messages for guaranteed order.

This option has influence only if guaranteed processing order is enabled.

Parameters:

excludeFailedState - true if you want to exclude FAILED state

getId

public String getId()

Gets funnel component identifier.

Specified by:

getId in interface org.apache.camel.spi.HasId

Overrides:

getId in class org.apache.camel.impl.DefaultEndpoint

Returns:

funnel component identifier

setId

public void setId(String id)