public class DisruptorComponent
extends org.apache.camel.impl.UriEndpointComponent
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BUFFER_SIZE |
static int |
MAX_CONCURRENT_CONSUMERS |
Constructor and Description |
---|
DisruptorComponent() |
Modifier and Type | Method and Description |
---|---|
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)
To configure the ring buffer size
|
void |
setDefaultBlockWhenFull(boolean defaultBlockWhenFull)
To configure the default value for block when full
The default value is true.
|
void |
setDefaultConcurrentConsumers(int defaultConcurrentConsumers)
To configure the default number of concurrent consumers
|
void |
setDefaultMultipleConsumers(boolean defaultMultipleConsumers)
To configure the default value for multiple consumers
|
void |
setDefaultProducerType(DisruptorProducerType defaultProducerType)
To configure the default value for DisruptorProducerType
The default value is Multi.
|
void |
setDefaultWaitStrategy(DisruptorWaitStrategy defaultWaitStrategy)
To configure the default value for DisruptorWaitStrategy
The default value is Blocking.
|
void |
setQueueSize(int size)
Deprecated.
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, doStart, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public static final int DEFAULT_BUFFER_SIZE
public static final int MAX_CONCURRENT_CONSUMERS
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultComponent
Exception
public Map<String,DisruptorReference> getDisruptors()
public int getDefaultConcurrentConsumers()
public void setDefaultConcurrentConsumers(int defaultConcurrentConsumers)
public boolean isDefaultMultipleConsumers()
public void setDefaultMultipleConsumers(boolean defaultMultipleConsumers)
public DisruptorProducerType getDefaultProducerType()
public void setDefaultProducerType(DisruptorProducerType defaultProducerType)
public DisruptorWaitStrategy getDefaultWaitStrategy()
public void setDefaultWaitStrategy(DisruptorWaitStrategy defaultWaitStrategy)
public boolean isDefaultBlockWhenFull()
public void setDefaultBlockWhenFull(boolean defaultBlockWhenFull)
@Deprecated public void setQueueSize(int size)
@Deprecated public int getQueueSize()
public void setBufferSize(int size)
public int getBufferSize()
public void onShutdownEndpoint(DisruptorEndpoint disruptorEndpoint)
Apache Camel