org.apache.camel.component.disruptor.vm
Class DisruptorVmComponent

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultComponent
          extended by org.apache.camel.component.disruptor.DisruptorComponent
              extended by org.apache.camel.component.disruptor.vm.DisruptorVmComponent
All Implemented Interfaces:
org.apache.camel.CamelContextAware, org.apache.camel.Component, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class DisruptorVmComponent
extends DisruptorComponent

An implementation of the VM components for asynchronous SEDA exchanges on a LMAX Disruptor within the classloader tree containing the camel-disruptor.jar. i.e. to handle communicating across CamelContext instances and possibly across web application contexts, providing that camel-disruptor.jar is on the system classpath.


Field Summary
protected static Map<String,DisruptorReference> DISRUPTORS
           
 
Fields inherited from class org.apache.camel.component.disruptor.DisruptorComponent
DEFAULT_BUFFER_SIZE, MAX_CONCURRENT_CONSUMERS
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
DisruptorVmComponent()
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
 Map<String,DisruptorReference> getDisruptors()
           
 
Methods inherited from class org.apache.camel.component.disruptor.DisruptorComponent
createEndpoint, getBufferSize, getDefaultConcurrentConsumers, getDefaultProducerType, getDefaultWaitStrategy, getDisruptorKey, getQueueSize, isDefaultBlockWhenFull, isDefaultMultipleConsumers, onShutdownEndpoint, setBufferSize, setDefaultBlockWhenFull, setDefaultConcurrentConsumers, setDefaultMultipleConsumers, setDefaultProducerType, setDefaultWaitStrategy, setQueueSize
 
Methods inherited from class org.apache.camel.impl.DefaultComponent
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, 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

DISRUPTORS

protected static final Map<String,DisruptorReference> DISRUPTORS
Constructor Detail

DisruptorVmComponent

public DisruptorVmComponent()
Method Detail

getDisruptors

public Map<String,DisruptorReference> getDisruptors()
Overrides:
getDisruptors in class DisruptorComponent

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class org.apache.camel.impl.DefaultComponent
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class DisruptorComponent
Throws:
Exception


Apache Camel