@UriEndpoint(firstVersion="1.1.0",
scheme="vm",
title="VM",
syntax="vm:name",
consumerClass=VmConsumer.class,
label="core,endpoint")
public class VmEndpoint
extends SedaEndpoint
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
VmEndpoint(String endpointUri,
Component component,
BlockingQueue<Exchange> queue) |
VmEndpoint(String endpointUri,
Component component,
BlockingQueue<Exchange> queue,
int concurrentConsumers) |
VmEndpoint(String endpointUri,
Component component,
BlockingQueueFactory<Exchange> queueFactory,
int concurrentConsumers) |
| Modifier and Type | Method and Description |
|---|---|
protected VmConsumer |
createNewConsumer(Processor processor) |
createConsumer, createPollingConsumer, createProducer, createQueue, doShutdown, doStart, getComponent, getConcurrentConsumers, getConsumerMulticastProcessor, getConsumers, getCurrentQueueSize, getExchanges, getPollTimeout, getProducers, getQueue, getQueueReference, getSize, getTimeout, getWaitForTaskToComplete, hasConsumers, isBlockWhenFull, isDiscardIfNoConsumers, isFailIfNoConsumers, isLimitConcurrentConsumers, isMultipleConsumers, isMultipleConsumersSupported, isPurgeWhenStopping, isSingleton, purgeQueue, setBlockWhenFull, setConcurrentConsumers, setDiscardIfNoConsumers, setFailIfNoConsumers, setLimitConcurrentConsumers, setMultipleConsumers, setPollTimeout, setPurgeWhenStopping, setQueue, setSize, setTimeout, setWaitForTaskToComplete, shutdown, stop, updateMulticastProcessorconfigureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toStringdoResume, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, start, suspendclone, finalize, getClass, notify, notifyAll, wait, wait, waitconfigureProperties, createExchange, createExchange, createExchange, getCamelContext, getEndpointConfiguration, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContextpublic VmEndpoint(String endpointUri, Component component, BlockingQueue<Exchange> queue)
public VmEndpoint(String endpointUri, Component component, BlockingQueue<Exchange> queue, int concurrentConsumers)
public VmEndpoint(String endpointUri, Component component, BlockingQueueFactory<Exchange> queueFactory, int concurrentConsumers)
protected VmConsumer createNewConsumer(Processor processor)
createNewConsumer in class SedaEndpointApache Camel