A B C D E G H I M O P R S T V Y 
All Classes All Packages

A

AbstractSynchronizedExchange - Class in org.apache.camel.component.disruptor
 
AbstractSynchronizedExchange(Exchange) - Constructor for class org.apache.camel.component.disruptor.AbstractSynchronizedExchange
 
addEndpoint(DisruptorEndpoint) - Method in class org.apache.camel.component.disruptor.DisruptorReference
 

B

Blocking - org.apache.camel.component.disruptor.DisruptorWaitStrategy
Blocking strategy that uses a lock and condition variable for EventProcessors waiting on a barrier.
buildUri(String, Map<String, Object>, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorEndpointUriFactory
 
buildUri(String, Map<String, Object>, boolean) - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmEndpointUriFactory
 
BusySpin - org.apache.camel.component.disruptor.DisruptorWaitStrategy
Busy Spin strategy that uses a busy spin loop for EventProcessors waiting on a barrier.

C

cancelAndGetOriginalExchange() - Method in class org.apache.camel.component.disruptor.AbstractSynchronizedExchange
 
cancelAndGetOriginalExchange() - Method in class org.apache.camel.component.disruptor.MultipleConsumerSynchronizedExchange
 
cancelAndGetOriginalExchange() - Method in interface org.apache.camel.component.disruptor.SynchronizedExchange
 
configure(CamelContext, Object, String, Object, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorComponentConfigurer
 
configure(CamelContext, Object, String, Object, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorEndpointConfigurer
 
consumed(Exchange) - Method in class org.apache.camel.component.disruptor.MultipleConsumerSynchronizedExchange
 
consumed(Exchange) - Method in class org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange
 
consumed(Exchange) - Method in interface org.apache.camel.component.disruptor.SynchronizedExchange
 
createConsumer(Processor) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
createProducer() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
createWaitStrategyInstance() - Method in enum org.apache.camel.component.disruptor.DisruptorWaitStrategy
 

D

DEFAULT_BUFFER_SIZE - Static variable in class org.apache.camel.component.disruptor.DisruptorComponent
 
deferShutdown(ShutdownRunningTask) - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
DISRUPTOR_IGNORE_EXCHANGE - Static variable in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
DisruptorComponent - Class in org.apache.camel.component.disruptor
An implementation of the Disruptor component for asynchronous SEDA exchanges on an LMAX Disruptor within a CamelContext
DisruptorComponent() - Constructor for class org.apache.camel.component.disruptor.DisruptorComponent
 
DisruptorComponentConfigurer - Class in org.apache.camel.component.disruptor
Generated by camel build tools - do NOT edit this file!
DisruptorComponentConfigurer() - Constructor for class org.apache.camel.component.disruptor.DisruptorComponentConfigurer
 
DisruptorConsumer - Class in org.apache.camel.component.disruptor
A Consumer for the Disruptor component.
DisruptorConsumer(DisruptorEndpoint, Processor) - Constructor for class org.apache.camel.component.disruptor.DisruptorConsumer
 
DisruptorEndpoint - Class in org.apache.camel.component.disruptor
Provides asynchronous SEDA behavior using LMAX Disruptor.
DisruptorEndpoint(String, Component, DisruptorReference) - Constructor for class org.apache.camel.component.disruptor.DisruptorEndpoint
 
DisruptorEndpointConfigurer - Class in org.apache.camel.component.disruptor
Generated by camel build tools - do NOT edit this file!
DisruptorEndpointConfigurer() - Constructor for class org.apache.camel.component.disruptor.DisruptorEndpointConfigurer
 
DisruptorEndpointUriFactory - Class in org.apache.camel.component.disruptor
Generated by camel build tools - do NOT edit this file!
DisruptorEndpointUriFactory() - Constructor for class org.apache.camel.component.disruptor.DisruptorEndpointUriFactory
 
DisruptorNotStartedException - Exception in org.apache.camel.component.disruptor
This exception is thrown when a producer attempts to publish an exchange while the Disruptor is not yet started or already shut down
DisruptorNotStartedException() - Constructor for exception org.apache.camel.component.disruptor.DisruptorNotStartedException
 
DisruptorNotStartedException(String) - Constructor for exception org.apache.camel.component.disruptor.DisruptorNotStartedException
 
DisruptorNotStartedException(String, Throwable) - Constructor for exception org.apache.camel.component.disruptor.DisruptorNotStartedException
 
DisruptorNotStartedException(Throwable) - Constructor for exception org.apache.camel.component.disruptor.DisruptorNotStartedException
 
DisruptorProducer - Class in org.apache.camel.component.disruptor
A Producer for the Disruptor component.
DisruptorProducer(DisruptorEndpoint, WaitForTaskToComplete, long, boolean) - Constructor for class org.apache.camel.component.disruptor.DisruptorProducer
 
DisruptorProducerType - Enum in org.apache.camel.component.disruptor
This enumeration re-enumerated the values of the ProducerType according to the Camel Case convention used in Camel.
DisruptorReference - Class in org.apache.camel.component.disruptor
Holder for Disruptor references.
DISRUPTORS - Static variable in class org.apache.camel.component.disruptor.vm.DisruptorVmComponent
 
DisruptorVmComponent - Class in org.apache.camel.component.disruptor.vm
An implementation of the VM components for asynchronous SEDA exchanges on a LMAX Disruptor within the classloader tree containing the camel-disruptor.jar.
DisruptorVmComponent() - Constructor for class org.apache.camel.component.disruptor.vm.DisruptorVmComponent
 
DisruptorVmEndpointUriFactory - Class in org.apache.camel.component.disruptor.vm
Generated by camel build tools - do NOT edit this file!
DisruptorVmEndpointUriFactory() - Constructor for class org.apache.camel.component.disruptor.vm.DisruptorVmEndpointUriFactory
 
DisruptorWaitStrategy - Enum in org.apache.camel.component.disruptor
This enumeration holds all values that may be used as the WaitStrategy used by producers on a Disruptor.
doInit() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
doResume() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
doShutdown() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
doStart() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
doStart() - Method in class org.apache.camel.component.disruptor.DisruptorProducer
 
doStart() - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmComponent
 
doStop() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
doStop() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
doStop() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
doStop() - Method in class org.apache.camel.component.disruptor.DisruptorProducer
 
doStop() - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmComponent
 
doSuspend() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 

E

equals(Object) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
ExchangeEvent - Class in org.apache.camel.component.disruptor
This is a mutable reference to an Exchange, used as contents of the Disruptors ringbuffer
ExchangeEvent() - Constructor for class org.apache.camel.component.disruptor.ExchangeEvent
 

G

getBufferSize() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
getBufferSize() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getBufferSize() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
getComponent() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getConcurrentConsumers() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getConsumers() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Returns the current active consumers on this endpoint
getDefaultConcurrentConsumers() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
getDefaultProducerType() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
getDefaultWaitStrategy() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
getDisruptorKey(String) - Static method in class org.apache.camel.component.disruptor.DisruptorComponent
 
getDisruptors() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
getDisruptors() - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmComponent
 
getEndpoint() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
getEndpoint() - Method in class org.apache.camel.component.disruptor.DisruptorProducer
 
getEndpointCount() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
getExceptionHandler() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
getExchange() - Method in class org.apache.camel.component.disruptor.AbstractSynchronizedExchange
 
getExchange() - Method in interface org.apache.camel.component.disruptor.SynchronizedExchange
 
getName() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getName() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
getOptionType(String, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorComponentConfigurer
 
getOptionType(String, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorEndpointConfigurer
 
getOptionValue(Object, String, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorComponentConfigurer
 
getOptionValue(Object, String, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorEndpointConfigurer
 
getPendingExchangeCount() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getPendingExchangeCount() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
getPendingExchangesSize() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
getProcessor() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
getProducers() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Returns the current active producers on this endpoint
getProducerType() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getProducerType() - Method in enum org.apache.camel.component.disruptor.DisruptorProducerType
 
getRemainingCapacity() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getRemainingCapacity() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
getSize() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getSynchronizedExchange() - Method in class org.apache.camel.component.disruptor.ExchangeEvent
 
getTimeout() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getWaitForTaskToComplete() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getWaitStrategy() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getWaitStrategy() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
getWaitStrategyClass() - Method in enum org.apache.camel.component.disruptor.DisruptorWaitStrategy
 

H

hashCode() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
hasNullReference() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 

I

isBlockWhenFull() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
isDefaultBlockWhenFull() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
isDefaultMultipleConsumers() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
isEnabled(String) - Method in class org.apache.camel.component.disruptor.DisruptorEndpointUriFactory
 
isEnabled(String) - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmEndpointUriFactory
 
isLenientProperties() - Method in class org.apache.camel.component.disruptor.DisruptorEndpointUriFactory
 
isLenientProperties() - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmEndpointUriFactory
 
isMultipleConsumers() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
isMultipleConsumersSupported() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 

M

MAX_CONCURRENT_CONSUMERS - Static variable in class org.apache.camel.component.disruptor.DisruptorComponent
 
Multi - org.apache.camel.component.disruptor.DisruptorProducerType
Create a RingBuffer supporting multiple event publishers to the Disruptors RingBuffer
MultipleConsumerSynchronizedExchange - Class in org.apache.camel.component.disruptor
Implementation of the SynchronizedExchange interface that correctly handles all completion synchronisation courtesies for multiple consumers.
MultipleConsumerSynchronizedExchange(Exchange, int) - Constructor for class org.apache.camel.component.disruptor.MultipleConsumerSynchronizedExchange
 

O

onShutdownEndpoint(DisruptorEndpoint) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
org.apache.camel.component.disruptor - package org.apache.camel.component.disruptor
 
org.apache.camel.component.disruptor.vm - package org.apache.camel.component.disruptor.vm
 

P

performSynchronization() - Method in class org.apache.camel.component.disruptor.AbstractSynchronizedExchange
 
prepareShutdown(boolean, boolean) - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
process(Exchange, AsyncCallback) - Method in class org.apache.camel.component.disruptor.DisruptorProducer
 
propertyNames() - Method in class org.apache.camel.component.disruptor.DisruptorEndpointUriFactory
 
propertyNames() - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmEndpointUriFactory
 
publish(Exchange) - Method in class org.apache.camel.component.disruptor.DisruptorReference
 

R

reconfigure() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
removeEndpoint(DisruptorEndpoint) - Method in class org.apache.camel.component.disruptor.DisruptorReference
 

S

secretPropertyNames() - Method in class org.apache.camel.component.disruptor.DisruptorEndpointUriFactory
 
secretPropertyNames() - Method in class org.apache.camel.component.disruptor.vm.DisruptorVmEndpointUriFactory
 
setBlockWhenFull(boolean) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Whether a thread that sends messages to a full Disruptor will block until the ringbuffer's capacity is no longer exhausted.
setBufferSize(int) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
To configure the ring buffer size
setConcurrentConsumers(int) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Number of concurrent threads processing exchanges.
setDefaultBlockWhenFull(boolean) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
To configure the default value for block when full
setDefaultConcurrentConsumers(int) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
To configure the default number of concurrent consumers
setDefaultMultipleConsumers(boolean) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
To configure the default value for multiple consumers
setDefaultProducerType(DisruptorProducerType) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
To configure the default value for DisruptorProducerType
setDefaultWaitStrategy(DisruptorWaitStrategy) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
To configure the default value for DisruptorWaitStrategy
setExceptionHandler(ExceptionHandler) - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
setExchange(Exchange, int) - Method in class org.apache.camel.component.disruptor.ExchangeEvent
 
setMultipleConsumers(boolean) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Specifies whether multiple consumers are allowed.
setProducerType(DisruptorProducerType) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Defines the producers allowed on the Disruptor.
setSize(int) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
The maximum capacity of the Disruptors ringbuffer Will be effectively increased to the nearest power of two.
setTimeout(long) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Timeout (in milliseconds) before a producer will stop waiting for an asynchronous task to complete.
setWaitForTaskToComplete(WaitForTaskToComplete) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Option to specify whether the caller should wait for the async task to complete or not before continuing.
setWaitStrategy(DisruptorWaitStrategy) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Defines the strategy used by consumer threads to wait on new exchanges to be published.
Single - org.apache.camel.component.disruptor.DisruptorProducerType
Create a RingBuffer with a single event publisher to the Disruptors RingBuffer
SingleConsumerSynchronizedExchange - Class in org.apache.camel.component.disruptor
Implementation of the SynchronizedExchange interface optimized for single consumers.
SingleConsumerSynchronizedExchange(Exchange) - Constructor for class org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange
 
Sleeping - org.apache.camel.component.disruptor.DisruptorWaitStrategy
Sleeping strategy that initially spins, then uses a Thread.yield(), and eventually for the minimum number of nanos the OS and JVM will allow while the EventProcessors are waiting on a barrier.
synchronizations - Variable in class org.apache.camel.component.disruptor.AbstractSynchronizedExchange
 
SynchronizedExchange - Interface in org.apache.camel.component.disruptor
This interface describes an immutable container of an Exchange and provides handles for DisruptorConsumers to correctly deal with the on completion synchronization, even in multicast circumstances.

T

toString() - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
toString() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
toString() - Method in class org.apache.camel.component.disruptor.ExchangeEvent
 
tryPublish(Exchange) - Method in class org.apache.camel.component.disruptor.DisruptorReference
 

V

valueOf(String) - Static method in enum org.apache.camel.component.disruptor.DisruptorProducerType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.camel.component.disruptor.DisruptorWaitStrategy
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.camel.component.disruptor.DisruptorProducerType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.camel.component.disruptor.DisruptorWaitStrategy
Returns an array containing the constants of this enum type, in the order they are declared.

Y

Yielding - org.apache.camel.component.disruptor.DisruptorWaitStrategy
Yielding strategy that uses a Thread.yield() for EventProcessors waiting on a barrier after an initially spinning.
A B C D E G H I M O P R S T V Y 
All Classes All Packages