public class MsgFunnelEndpoint
extends org.apache.camel.impl.DefaultEndpoint
msg-funnel
component.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_IDLE_INTERVAL |
Constructor and Description |
---|
MsgFunnelEndpoint(String endpointUri,
org.apache.camel.Component component)
Creates new endpoint.
|
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) |
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
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public static final int DEFAULT_IDLE_INTERVAL
public MsgFunnelEndpoint(String endpointUri, org.apache.camel.Component component)
endpointUri
- the URIcomponent
- the "msg-funnel" componentpublic org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public int getIdleInterval()
public void setIdleInterval(int idleInterval)
public boolean isGuaranteedOrder()
true
if funnel component should guaranteed order of processing messages.true
if funnel component should guaranteed order of processing messages otherwise false
public void setGuaranteedOrder(boolean guaranteedOrder)
public boolean isExcludeFailedState()
public void setExcludeFailedState(boolean excludeFailedState)
This option has influence only if guaranteed processing order
is enabled.
excludeFailedState
- true
if you want to exclude FAILED statepublic String getId()
getId
in interface org.apache.camel.spi.HasId
getId
in class org.apache.camel.impl.DefaultEndpoint
public void setId(String id)
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.