Package org.apache.camel.component.vm
Class VmComponent
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultComponent
-
- org.apache.camel.component.seda.SedaComponent
-
- org.apache.camel.component.vm.VmComponent
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Component
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
@Component("vm") public class VmComponent extends org.apache.camel.component.seda.SedaComponent
The VM component is for asynchronous SEDA exchanges on aBlockingQueue
within the classloader tree containing the camel-core.jar. i.e. to handle communicating across CamelContext instances and possibly across web application contexts, providing that camel-core.jar is on the system classpath.
-
-
Field Summary
Fields Modifier and Type Field Description protected static Map<String,VmEndpoint>
ENDPOINTS
protected static Map<String,org.apache.camel.component.seda.QueueReference>
QUEUES
-
Constructor Summary
Constructors Constructor Description VmComponent()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.camel.Endpoint
createEndpoint(String uri, String remaining, Map<String,Object> parameters)
protected VmEndpoint
createEndpoint(String endpointUri, org.apache.camel.Component component, BlockingQueue<org.apache.camel.Exchange> queue, int concurrentConsumers)
protected VmEndpoint
createEndpoint(String endpointUri, org.apache.camel.Component component, org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange> queueFactory, int concurrentConsumers)
protected void
doStart()
protected void
doStop()
org.apache.camel.component.seda.QueueReference
getQueueReference(String key)
Map<String,org.apache.camel.component.seda.QueueReference>
getQueues()
-
Methods inherited from class org.apache.camel.component.seda.SedaComponent
getConcurrentConsumers, getDefaultOfferTimeout, getDefaultQueueFactory, getOrCreateQueue, getQueueKey, getQueueSize, isDefaultBlockWhenFull, isDefaultDiscardWhenFull, registerQueue, setConcurrentConsumers, setDefaultBlockWhenFull, setDefaultDiscardWhenFull, setDefaultOfferTimeout, setDefaultQueueFactory, setQueueSize
-
Methods inherited from class org.apache.camel.support.DefaultComponent
afterConfiguration, createEndpoint, createEndpoint, doBuild, doInit, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getComponentPropertyConfigurer, getDefaultName, getEndpointPropertyConfigurer, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, resolveRawParameterValues, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setLazyStartProducer, setProperties, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
-
-
Field Detail
-
ENDPOINTS
protected static final Map<String,VmEndpoint> ENDPOINTS
-
-
Method Detail
-
getQueues
public Map<String,org.apache.camel.component.seda.QueueReference> getQueues()
- Overrides:
getQueues
in classorg.apache.camel.component.seda.SedaComponent
-
getQueueReference
public org.apache.camel.component.seda.QueueReference getQueueReference(String key)
- Overrides:
getQueueReference
in classorg.apache.camel.component.seda.SedaComponent
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.DefaultComponent
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.component.seda.SedaComponent
- Throws:
Exception
-
createEndpoint
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
- Overrides:
createEndpoint
in classorg.apache.camel.component.seda.SedaComponent
- Throws:
Exception
-
createEndpoint
protected VmEndpoint createEndpoint(String endpointUri, org.apache.camel.Component component, org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange> queueFactory, int concurrentConsumers)
- Overrides:
createEndpoint
in classorg.apache.camel.component.seda.SedaComponent
-
createEndpoint
protected VmEndpoint createEndpoint(String endpointUri, org.apache.camel.Component component, BlockingQueue<org.apache.camel.Exchange> queue, int concurrentConsumers)
- Overrides:
createEndpoint
in classorg.apache.camel.component.seda.SedaComponent
-
-