@UriEndpoint(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) |
browseAllMessagesAsXml, browseExchange, browseMessageAsXml, browseMessageBody, browseRangeMessagesAsXml, createConsumer, createPollingConsumer, createProducer, createQueue, doShutdown, doStart, getCamelId, getCamelManagementName, getComponent, getConcurrentConsumers, getConsumerMulticastProcessor, getConsumers, getCurrentQueueSize, getEndpointUri, getExchanges, getPollTimeout, getProducers, getQueue, getQueueReference, getSize, getState, getTimeout, getWaitForTaskToComplete, hasConsumers, isBlockWhenFull, isFailIfNoConsumers, isMultipleConsumers, isMultipleConsumersSupported, isPurgeWhenStopping, isSingleton, purgeQueue, queueSize, setBlockWhenFull, setConcurrentConsumers, setFailIfNoConsumers, setMultipleConsumers, setPollTimeout, setPurgeWhenStopping, setQueue, setSize, setTimeout, setWaitForTaskToComplete, shutdown, stop, updateMulticastProcessorconfigureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, doStop, equals, getCamelContext, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, 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, 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