Class VmEndpoint

  • All Implemented Interfaces:
    AutoCloseable, org.apache.camel.AsyncEndpoint, org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.BrowsableEndpoint, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

    @UriEndpoint(firstVersion="1.1.0",
                 scheme="vm",
                 title="VM",
                 syntax="vm:name",
                 category={CORE,ENDPOINT})
    public class VmEndpoint
    extends org.apache.camel.component.seda.SedaEndpoint
    Call another endpoint in the same CamelContext asynchronously.
    • Field Summary

      • Fields inherited from class org.apache.camel.support.service.BaseService

        BUILT, FAILED, INITIALIZED, INITIALIZING, lock, NEW, SHUTDOWN, SHUTTING_DOWN, STARTED, STARTING, status, STOPPED, STOPPING, SUSPENDED, SUSPENDING
    • Constructor Summary

      Constructors 
      Constructor Description
      VmEndpoint​(String endpointUri, org.apache.camel.Component component, BlockingQueue<org.apache.camel.Exchange> queue)  
      VmEndpoint​(String endpointUri, org.apache.camel.Component component, BlockingQueue<org.apache.camel.Exchange> queue, int concurrentConsumers)  
      VmEndpoint​(String endpointUri, org.apache.camel.Component component, org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange> queueFactory, int concurrentConsumers)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected VmConsumer createNewConsumer​(org.apache.camel.Processor processor)  
      • Methods inherited from class org.apache.camel.component.seda.SedaEndpoint

        createConsumer, createPollingConsumer, createProducer, createQueue, doInit, doShutdown, doStart, getComponent, getConcurrentConsumers, getConsumerMulticastProcessor, getConsumers, getCurrentQueueSize, getExchanges, getOfferTimeout, getPollTimeout, getProducers, getQueue, getQueueReference, getSize, getTimeout, getWaitForTaskToComplete, hasConsumers, isBlockWhenFull, isDiscardIfNoConsumers, isDiscardWhenFull, isFailIfNoConsumers, isLimitConcurrentConsumers, isMultipleConsumers, isMultipleConsumersSupported, isPurgeWhenStopping, purgeQueue, setBlockWhenFull, setConcurrentConsumers, setDiscardIfNoConsumers, setDiscardWhenFull, setFailIfNoConsumers, setLimitConcurrentConsumers, setMultipleConsumers, setOfferTimeout, setPollTimeout, setPurgeWhenStopping, setQueue, setSize, setTimeout, setWaitForTaskToComplete, shutdown, stop, updateMulticastProcessor
      • Methods inherited from class org.apache.camel.support.DefaultEndpoint

        configureConsumer, configureExchange, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, doStop, equals, getCamelContext, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isPollingConsumerCopy, isSingleton, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerCopy, setPollingConsumerQueueSize, setProperties, toString
      • Methods inherited from class org.apache.camel.support.service.BaseService

        build, doBuild, doFail, doLifecycleChange, doResume, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, start, suspend
      • Methods inherited from interface org.apache.camel.Endpoint

        configureExchange, configureProperties, createAsyncProducer, createExchange, createExchange, getCamelContext, getEndpointBaseUri, getEndpointKey, getEndpointUri, isLenientProperties, isSingletonProducer, setCamelContext
      • Methods inherited from interface org.apache.camel.IsSingleton

        isSingleton
      • Methods inherited from interface org.apache.camel.Service

        build, close, init, start
      • Methods inherited from interface org.apache.camel.StatefulService

        getStatus, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspending
      • Methods inherited from interface org.apache.camel.SuspendableService

        isSuspended, resume, suspend
    • Constructor Detail

      • VmEndpoint

        public VmEndpoint​(String endpointUri,
                          org.apache.camel.Component component,
                          BlockingQueue<org.apache.camel.Exchange> queue)
      • VmEndpoint

        public VmEndpoint​(String endpointUri,
                          org.apache.camel.Component component,
                          BlockingQueue<org.apache.camel.Exchange> queue,
                          int concurrentConsumers)
      • VmEndpoint

        public VmEndpoint​(String endpointUri,
                          org.apache.camel.Component component,
                          org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange> queueFactory,
                          int concurrentConsumers)
    • Method Detail

      • createNewConsumer

        protected VmConsumer createNewConsumer​(org.apache.camel.Processor processor)
        Overrides:
        createNewConsumer in class org.apache.camel.component.seda.SedaEndpoint