A B C D E G H I M O P R S T V Y
All Classes All Packages
All Classes All Packages
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
EventProcessor
s 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
EventProcessor
s 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
EventProcessor
s 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
DisruptorConsumer
s 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
EventProcessor
s waiting on a barrier after an initially spinning.
All Classes All Packages