org.apache.camel.component.disruptor
Class DisruptorComponent

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultComponent
          org.apache.camel.component.disruptor.DisruptorComponent

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

Direct Known Subclasses:

DisruptorVmComponent

public class DisruptorComponent
extends org.apache.camel.impl.DefaultComponent

An implementation of the Disruptor component for asynchronous SEDA exchanges on an LMAX Disruptor within a CamelContext

Field Summary

static int	DEFAULT_BUFFER_SIZE
static int	MAX_CONCURRENT_CONSUMERS

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

DisruptorComponent()

Method Summary

protected org.apache.camel.Endpoint	createEndpoint(String uri, String remaining, Map<String,Object> parameters)
protected void	doStop()
int	getBufferSize()
int	getDefaultConcurrentConsumers()
DisruptorProducerType	getDefaultProducerType()
DisruptorWaitStrategy	getDefaultWaitStrategy()
static String	getDisruptorKey(String uri)
Map<String,DisruptorReference>	getDisruptors()
int	getQueueSize() Deprecated.
boolean	isDefaultBlockWhenFull()
boolean	isDefaultMultipleConsumers()
void	onShutdownEndpoint(DisruptorEndpoint disruptorEndpoint)
void	setBufferSize(int size)
void	setDefaultBlockWhenFull(boolean defaultBlockWhenFull)
void	setDefaultConcurrentConsumers(int defaultConcurrentConsumers)
void	setDefaultMultipleConsumers(boolean defaultMultipleConsumers)
void	setDefaultProducerType(DisruptorProducerType defaultProducerType)
void	setDefaultWaitStrategy(DisruptorWaitStrategy defaultWaitStrategy)
void	setQueueSize(int size) Deprecated.

Methods inherited from class org.apache.camel.impl.DefaultComponent

afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, doStart, 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

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

MAX_CONCURRENT_CONSUMERS

public static final int MAX_CONCURRENT_CONSUMERS

See Also:

Constant Field Values

Constructor Detail

DisruptorComponent

public DisruptorComponent()

Method Detail

createEndpoint

protected org.apache.camel.Endpoint createEndpoint(String uri,
                                                   String remaining,
                                                   Map<String,Object> parameters)
                                            throws Exception

Specified by:

createEndpoint in class org.apache.camel.impl.DefaultComponent

Throws:

Exception

getDisruptorKey

public static String getDisruptorKey(String uri)

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultComponent

Throws:

Exception

getDisruptors

public Map<String,DisruptorReference> getDisruptors()

getDefaultConcurrentConsumers

public int getDefaultConcurrentConsumers()

setDefaultConcurrentConsumers

public void setDefaultConcurrentConsumers(int defaultConcurrentConsumers)

isDefaultMultipleConsumers

public boolean isDefaultMultipleConsumers()

setDefaultMultipleConsumers

public void setDefaultMultipleConsumers(boolean defaultMultipleConsumers)

getDefaultProducerType

public DisruptorProducerType getDefaultProducerType()

setDefaultProducerType

public void setDefaultProducerType(DisruptorProducerType defaultProducerType)

getDefaultWaitStrategy

public DisruptorWaitStrategy getDefaultWaitStrategy()

setDefaultWaitStrategy

public void setDefaultWaitStrategy(DisruptorWaitStrategy defaultWaitStrategy)

isDefaultBlockWhenFull

public boolean isDefaultBlockWhenFull()

setDefaultBlockWhenFull

public void setDefaultBlockWhenFull(boolean defaultBlockWhenFull)

setQueueSize

@Deprecated
public void setQueueSize(int size)

Deprecated.

getQueueSize

@Deprecated
public int getQueueSize()

Deprecated.

setBufferSize

public void setBufferSize(int size)

getBufferSize

public int getBufferSize()

onShutdownEndpoint

public void onShutdownEndpoint(DisruptorEndpoint disruptorEndpoint)