A C D E G H I M O P R S T V 

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
 

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
 
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
 
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
An implementation of the Disruptor component for asynchronous SEDA exchanges on an LMAX Disruptor within a CamelContext
DisruptorEndpoint(String, Component, DisruptorReference, int, boolean, boolean) - Constructor for class org.apache.camel.component.disruptor.DisruptorEndpoint
 
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
 
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.
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.DisruptorEndpoint
 
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
 
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
 
getProducers() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
Returns the current active producers on this endpoint
getProducerType() - Method in enum org.apache.camel.component.disruptor.DisruptorProducerType
 
getQueueSize() - Method in class org.apache.camel.component.disruptor.DisruptorComponent
Deprecated.
getRemainingCapacity() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
getRemainingCapacity() - Method in class org.apache.camel.component.disruptor.DisruptorReference
 
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.DisruptorReference
 

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
 
isMultipleConsumers() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
isMultipleConsumersSupported() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
isSingleton() - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 

M

MAX_CONCURRENT_CONSUMERS - Static variable in class org.apache.camel.component.disruptor.DisruptorComponent
 
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) - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
process(Exchange, AsyncCallback) - Method in class org.apache.camel.component.disruptor.DisruptorProducer
 
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

setBlockWhenFull(boolean) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
setBufferSize(int) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
setDefaultBlockWhenFull(boolean) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
setDefaultConcurrentConsumers(int) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
setDefaultMultipleConsumers(boolean) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
setDefaultProducerType(DisruptorProducerType) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
setDefaultWaitStrategy(DisruptorWaitStrategy) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
 
setExceptionHandler(ExceptionHandler) - Method in class org.apache.camel.component.disruptor.DisruptorConsumer
 
setExchange(Exchange, int) - Method in class org.apache.camel.component.disruptor.ExchangeEvent
 
setQueueSize(int) - Method in class org.apache.camel.component.disruptor.DisruptorComponent
Deprecated.
setTimeout(long) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
setWaitForTaskToComplete(WaitForTaskToComplete) - Method in class org.apache.camel.component.disruptor.DisruptorEndpoint
 
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
 
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.
A C D E G H I M O P R S T V 

Apache Camel