Uses of Interface
org.apache.camel.Exchange

Packages that use Exchange

Package	Description
org.apache.camel	The core Camel API.
org.apache.camel.cloudevents
org.apache.camel.spi

Uses of Exchange in org.apache.camel

Subinterfaces of Exchange in org.apache.camel

Modifier and Type	Interface	Description
interface	PooledExchange	Pooled Exchange which contains the methods and APIs that are not intended for Camel end users but used internally by Camel for optimizing memory footprint by reusing exchanges created by Consumers via ExchangeFactory.

Methods in org.apache.camel that return Exchange

Modifier and Type	Method	Description
@Nullable Exchange	AggregationStrategy.aggregate(@Nullable Exchange oldExchange, @Nullable Exchange newExchange)	Aggregates an old and new exchange together to create a single combined exchange
default @Nullable Exchange	AggregationStrategy.aggregate(@Nullable Exchange oldExchange, @Nullable Exchange newExchange, Exchange inputExchange)	Aggregates an old and new exchange together to create a single combined exchange.
Exchange	Exchange.copy()	Creates a copy of the current message exchange so that it can be forwarded to another destination
Exchange	ExchangeExtension.createCopyWithProperties(CamelContext context)	Create a new exchange copied from this, with the context set to the given context
Exchange	Consumer.createExchange(boolean autoRelease)	Creates an Exchange that was consumed.
Exchange	Endpoint.createExchange()	Create a new exchange for communicating with this endpoint.
Exchange	Endpoint.createExchange(ExchangePattern pattern)	Create a new exchange for communicating with this endpoint with the specified ExchangePattern such as whether its going to be an ExchangePattern.InOnly or ExchangePattern.InOut exchange
@Nullable Exchange	CamelExchangeException.getExchange()	Returns the exchange which caused the exception
@Nullable Exchange	ExpectedBodyTypeException.getExchange()
@Nullable Exchange	ExpressionEvaluationException.getExchange()
@Nullable Exchange	Message.getExchange()	Returns the exchange this message is related to
@Nullable Exchange	RuntimeExchangeException.getExchange()	Returns the exchange which caused the exception
Exchange	ConsumerTemplate.receive(String endpointUri)	Receives from the endpoint, waiting until there is a response
@Nullable Exchange	ConsumerTemplate.receive(String endpointUri, long timeout)	Receives from the endpoint, waiting until there is a response or the timeout occurs
Exchange	ConsumerTemplate.receive(Endpoint endpoint)	Receives from the endpoint, waiting until there is a response.
@Nullable Exchange	ConsumerTemplate.receive(Endpoint endpoint, long timeout)	Receives from the endpoint, waiting until there is a response or the timeout occurs
@Nullable Exchange	DynamicPollingConsumer.receive(Exchange exchange)	Waits until a message is available and then returns it.
@Nullable Exchange	DynamicPollingConsumer.receive(Exchange exchange, long timeout)	Attempts to receive a message exchange, waiting up to the given timeout to expire if a message is not yet available.
@Nullable Exchange	PollingConsumer.receive()	Waits until a message is available and then returns it.
@Nullable Exchange	PollingConsumer.receive(long timeout)	Attempts to receive a message exchange, waiting up to the given timeout to expire if a message is not yet available.
@Nullable Exchange	ConsumerTemplate.receiveNoWait(String endpointUri)	Receives from the endpoint, not waiting for a response if none exists.
@Nullable Exchange	ConsumerTemplate.receiveNoWait(Endpoint endpoint)	Receives from the endpoint, not waiting for a response if none exists.
@Nullable Exchange	DynamicPollingConsumer.receiveNoWait(Exchange exchange)	Attempts to receive a message exchange immediately without waiting and returning null if a message exchange is not available yet.
@Nullable Exchange	PollingConsumer.receiveNoWait()	Attempts to receive a message exchange immediately without waiting and returning null if a message exchange is not available yet.
Exchange	ProducerTemplate.request(String endpointUri, Processor processor)	Sends an exchange to an endpoint using a supplied processor Uses an ExchangePattern.InOut message exchange pattern.
Exchange	ProducerTemplate.request(Endpoint endpoint, Processor processor)	Sends an exchange to an endpoint using a supplied processor Uses an ExchangePattern.InOut message exchange pattern.
Exchange	FluentProducerTemplate.send()	Send to an endpoint (InOnly)
Exchange	ProducerTemplate.send(String endpointUri, Exchange exchange)	Sends the exchange to the given endpoint
Exchange	ProducerTemplate.send(String endpointUri, ExchangePattern pattern, Processor processor)	Sends an exchange to an endpoint using a supplied processor
Exchange	ProducerTemplate.send(String endpointUri, Processor processor)	Sends an exchange to an endpoint using a supplied processor
Exchange	ProducerTemplate.send(Endpoint endpoint, Exchange exchange)	Sends the exchange to the given endpoint
Exchange	ProducerTemplate.send(Endpoint endpoint, ExchangePattern pattern, Processor processor)	Sends an exchange to an endpoint using a supplied processor
Exchange	ProducerTemplate.send(Endpoint endpoint, ExchangePattern pattern, Processor processor, Processor resultProcessor)	Sends an exchange to an endpoint using a supplied processor
Exchange	ProducerTemplate.send(Endpoint endpoint, Processor processor)	Sends an exchange to an endpoint using a supplied processor
Exchange	ProducerTemplate.send(Exchange exchange)	Sends the exchange to the default endpoint Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().
Exchange	ProducerTemplate.send(Processor processor)	Sends an exchange to the default endpoint using a supplied processor Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().

Methods in org.apache.camel that return types with arguments of type Exchange

Modifier and Type	Method	Description
Future<Exchange>	FluentProducerTemplate.asyncSend()	Sends asynchronously to the given endpoint (InOnly).
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(String endpointUri, Exchange exchange)	Sends an asynchronous exchange to the given endpoint.
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(String endpointUri, Processor processor)	Sends an asynchronous exchange to the given endpoint.
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(Endpoint endpoint, Exchange exchange)	Sends an asynchronous exchange to the given endpoint.
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(Endpoint endpoint, Processor processor)	Sends an asynchronous exchange to the given endpoint.
CompletableFuture<Exchange>	AsyncProcessor.processAsync(Exchange exchange)

Methods in org.apache.camel with parameters of type Exchange

Modifier and Type	Method	Description
default boolean	NamedNode.acceptDebugger(Exchange exchange)	Whether this node can accept debugging the current exchange.
@Nullable Exchange	AggregationStrategy.aggregate(@Nullable Exchange oldExchange, @Nullable Exchange newExchange)	Aggregates an old and new exchange together to create a single combined exchange
default @Nullable Exchange	AggregationStrategy.aggregate(@Nullable Exchange oldExchange, @Nullable Exchange newExchange, Exchange inputExchange)	Aggregates an old and new exchange together to create a single combined exchange.
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(String endpointUri, Exchange exchange)	Sends an asynchronous exchange to the given endpoint.
CompletableFuture<Exchange>	ProducerTemplate.asyncSend(Endpoint endpoint, Exchange exchange)	Sends an asynchronous exchange to the given endpoint.
void	Endpoint.configureExchange(Exchange exchange)	Configures a newly created Exchange.
<T> @Nullable T	TypeConverter.convertTo(Class<T> type, @Nullable Exchange exchange, @Nullable Object value)	Converts the value to the specified type in the context of an exchange
@Nullable StreamCache	StreamCache.copy(Exchange exchange)	Create a copy of the stream.
void	ExchangeExtension.copyInternalProperties(Exchange target)	To copy the internal properties from this exchange to the target exchange
static String	CamelExchangeException.createExceptionMessage(@Nullable String message, @Nullable Exchange exchange, @Nullable Throwable cause)	Creates an exception message with the provided details.
protected static String	RuntimeExchangeException.createMessage(String message, @Nullable Exchange exchange)
default @Nullable AsyncCallback	Consumer.defaultConsumerCallback(Exchange exchange, boolean autoRelease)	The default callback to use with the consumer when calling the processor using asynchronous routing.
void	ConsumerTemplate.doneUoW(Exchange exchange)	If you have used any of the receive methods which returns a Exchange type then you need to invoke this method when you are done using the returned Exchange.
<T> @Nullable T	Expression.evaluate(Exchange exchange, Class<T> type)	Returns the value of the expression on the given exchange
void	ExchangeExtension.handoverCompletions(Exchange target)	Handover all the on completions from this exchange to the target exchange.
protected static String	NoSuchHeaderOrPropertyException.header(Exchange exchange, String headerName)
<T> T	TypeConverter.mandatoryConvertTo(Class<T> type, @Nullable Exchange exchange, @Nullable Object value)	Converts the value to the specified type in the context of an exchange
boolean	Predicate.matches(Exchange exchange)	Evaluates the predicate on the message exchange and returns true if this exchange matches the predicate
@Nullable String	BinaryPredicate.matchesReturningFailureMessage(Exchange exchange)	Evaluates the predicate on the message exchange and returns null if this exchange matches the predicate.
default void	AggregationStrategy.onCompletion(Exchange exchange)	The aggregated Exchange has completed Important: This method must not throw any exceptions.
default void	AggregationStrategy.onCompletion(Exchange exchange, Exchange inputExchange)	The aggregated Exchange has completed Important: This method must not throw any exceptions.
void	PooledExchange.OnDoneTask.onDone(Exchange exchange)
default void	AggregationStrategy.onOptimisticLockFailure(Exchange oldExchange, Exchange newExchange)	Callback when the aggregated Exchange fails to add in the OptimisticLockingAggregationRepository because of an OptimisticLockingAggregationRepository.OptimisticLockingException.
default boolean	AggregationStrategy.preComplete(@Nullable Exchange oldExchange, @Nullable Exchange newExchange)	Determines if the aggregation should complete the current group, and start a new group, or the aggregation should continue using the current group.
boolean	AsyncProcessor.process(Exchange exchange, AsyncCallback callback)	Processes the message exchange.
void	Processor.process(Exchange exchange)	Processes the message exchange
CompletableFuture<Exchange>	AsyncProcessor.processAsync(Exchange exchange)
protected static String	NoSuchHeaderOrPropertyException.property(Exchange exchange, String propertyName)
protected static String	NoSuchHeaderException.reason(Exchange exchange, String headerName)
protected static String	NoSuchPropertyException.reason(Exchange exchange, String propertyName)
@Nullable Exchange	DynamicPollingConsumer.receive(Exchange exchange)	Waits until a message is available and then returns it.
@Nullable Exchange	DynamicPollingConsumer.receive(Exchange exchange, long timeout)	Attempts to receive a message exchange, waiting up to the given timeout to expire if a message is not yet available.
@Nullable Exchange	DynamicPollingConsumer.receiveNoWait(Exchange exchange)	Attempts to receive a message exchange immediately without waiting and returning null if a message exchange is not available yet.
void	Consumer.releaseExchange(Exchange exchange, boolean autoRelease)	Releases the Exchange when its completed processing and no longer needed.
Exchange	ProducerTemplate.send(String endpointUri, Exchange exchange)	Sends the exchange to the given endpoint
Exchange	ProducerTemplate.send(Endpoint endpoint, Exchange exchange)	Sends the exchange to the given endpoint
Exchange	ProducerTemplate.send(Exchange exchange)	Sends the exchange to the default endpoint Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().
default void	AggregationStrategy.timeout(Exchange exchange, int index, int total, long timeout)	A timeout occurred.
<T> @Nullable T	TypeConverter.tryConvertTo(Class<T> type, @Nullable Exchange exchange, @Nullable Object value)	Tries to convert the value to the specified type in the context of an exchange, returning null if not possible to convert.
FluentProducerTemplate	FluentProducerTemplate.withExchange(Exchange exchange)	Set the exchange to use for send.
static CamelExecutionException	CamelExecutionException.wrapCamelExecutionException(@Nullable Exchange exchange, Throwable e)	Wraps the caused exception in a CamelExecutionException if its not already such an exception.

Method parameters in org.apache.camel with type arguments of type Exchange

Modifier and Type	Method	Description
FluentProducerTemplate	FluentProducerTemplate.withExchange(Supplier<Exchange> exchangeSupplier)	Set the exchangeSupplier which will be invoke to get the exchange to be used for send.

Constructors in org.apache.camel with parameters of type Exchange

Modifier	Constructor	Description
	CamelAuthorizationException(String message, Exchange exchange)
	CamelAuthorizationException(String message, Exchange exchange, Throwable cause)
	CamelExchangeException(@Nullable String message, @Nullable Exchange exchange)
	CamelExchangeException(@Nullable String message, @Nullable Exchange exchange, @Nullable Throwable cause)
	CamelExecutionException(String message, @Nullable Exchange exchange)
	CamelExecutionException(String message, @Nullable Exchange exchange, Throwable cause)
	CamelUnitOfWorkException(Exchange exchange, List<Exception> causes)
	ExchangeTimedOutException(@Nullable Exchange exchange, long timeout)
	ExchangeTimedOutException(@Nullable Exchange exchange, long timeout, String message)
	ExpectedBodyTypeException(Exchange exchange, Class<?> expectedBodyType)
	ExpressionEvaluationException(@Nullable Expression expression, String message, @Nullable Exchange exchange, @Nullable Throwable cause)
	ExpressionEvaluationException(@Nullable Expression expression, @Nullable Exchange exchange, @Nullable Throwable cause)
	InvalidPayloadException(Exchange exchange, Class<?> type)
	InvalidPayloadException(Exchange exchange, Class<?> type, Message message)
	InvalidPayloadException(Exchange exchange, Class<?> type, Message message, Throwable cause)
	InvalidPayloadRuntimeException(Exchange exchange, Class<?> type)
	InvalidPayloadRuntimeException(Exchange exchange, Class<?> type, Throwable cause)
	InvalidPayloadRuntimeException(Exchange exchange, Class<?> type, Message message)
	InvalidPayloadRuntimeException(Exchange exchange, Class<?> type, Message message, Throwable cause)
	NoSuchHeaderException(String message, Exchange exchange, String headerName)
	NoSuchHeaderException(Exchange exchange, String headerName, @Nullable Class<?> type)
	NoSuchHeaderOrPropertyException(Exchange exchange, String headerName, String propertyName, Class<?> type)
	NoSuchPropertyException(Exchange exchange, String propertyName)
	NoSuchPropertyException(Exchange exchange, String propertyName, @Nullable Class<?> type)
	NoSuchVariableException(Exchange exchange, String variableName)
	NoSuchVariableException(Exchange exchange, String variableName, Class<?> type)
	RollbackExchangeException(String message, Exchange exchange)
	RollbackExchangeException(String message, Exchange exchange, Throwable cause)
	RollbackExchangeException(Exchange exchange)
	RollbackExchangeException(Exchange exchange, Throwable cause)
	RuntimeExchangeException(String message, @Nullable Exchange exchange)
	RuntimeExchangeException(String message, @Nullable Exchange exchange, Throwable cause)
	ValidationException(@Nullable String message, @Nullable Exchange exchange, @Nullable Throwable cause)
	ValidationException(@Nullable Exchange exchange, @Nullable String message)

Uses of Exchange in org.apache.camel.cloudevents

Methods in org.apache.camel.cloudevents with parameters of type Exchange

Modifier and Type	Method	Description
default String	CloudEvent.getEventTime(Exchange exchange)	Construct event time from given Camel exchange.

Uses of Exchange in org.apache.camel.spi

Subinterfaces with type arguments of type Exchange in org.apache.camel.spi

Modifier and Type	Interface	Description
interface	ExchangeFactory	Factory used by Consumer (and PollingConsumer) to create the Exchange that carries an incoming message into Camel.
interface	ProcessorExchangeFactory	Factory used by Processor implementations (EIPs) when they create copies of the current Exchange for sub-routing.

Methods in org.apache.camel.spi that return Exchange

Modifier and Type	Method	Description
@Nullable Exchange	AggregationRepository.add(CamelContext camelContext, String key, Exchange exchange)	Add the given Exchange under the correlation key.
@Nullable Exchange	OptimisticLockingAggregationRepository.add(CamelContext camelContext, String key, @Nullable Exchange oldExchange, Exchange newExchange)	Add the given Exchange under the correlation key.
Exchange	ExchangeFactory.create(boolean autoRelease)	Gets a new Exchange
Exchange	ExchangeFactory.create(Endpoint fromEndpoint, boolean autoRelease)	Gets a new Exchange
Exchange	ProcessorExchangeFactory.create(Endpoint fromEndpoint, ExchangePattern exchangePattern)	Gets a new Exchange
Exchange	ProcessorExchangeFactory.createCopy(Exchange exchange)	Gets a copy of the given Exchange
Exchange	ProcessorExchangeFactory.createCorrelatedCopy(Exchange exchange, boolean handover)	Gets a copy of the given Exchange and the copy is correlated to the source
@Nullable Exchange	AggregationRepository.get(CamelContext camelContext, String key)	Gets the given exchange with the correlation key
@Nullable Exchange	ClaimCheckRepository.get(String key)	Gets the exchange from the repository.
@Nullable Exchange	ClaimCheckRepository.getAndRemove(String key)	Gets and removes the exchange from the repository.
Exchange	AsyncProcessorAwaitManager.AwaitThread.getExchange()	The exchange being processed by the other thread.
Exchange	CamelEvent.ExchangeEvent.getExchange()	Returns the exchange.
Exchange	InflightRepository.InflightExchange.getExchange()	The exchange being inflight
@Nullable Exchange	BacklogDebugger.getSuspendedExchange(String id)	Gets the exchanged suspended at the given breakpoint id or null if there is none at that id.
@Nullable Exchange	ClaimCheckRepository.pop()	Pops the repository and returns the latest.
@Nullable Exchange	ConsumerCache.receive(Endpoint endpoint)	Waits until a message is available and then returns it.
@Nullable Exchange	ConsumerCache.receive(Endpoint endpoint, long timeout)	Attempts to receive a message exchange, waiting up to the given timeout to expire if a message is not yet available.
@Nullable Exchange	ConsumerCache.receiveNoWait(Endpoint endpoint)	Attempts to receive a message exchange immediately without waiting and returning null if a message exchange is not available yet.
@Nullable Exchange	RecoverableAggregationRepository.recover(CamelContext camelContext, String exchangeId)	Recovers the exchange with the given exchange id
Exchange	ProducerCache.send(Endpoint endpoint, Exchange exchange, @Nullable Processor resultProcessor)	Sends the exchange to the given endpoint.

Methods in org.apache.camel.spi that return types with arguments of type Exchange

Modifier and Type	Method	Description
CompletableFuture<Exchange>	ProducerCache.asyncSendExchange(Endpoint endpoint, ExchangePattern pattern, Processor processor, @Nullable Processor resultProcessor, @Nullable Exchange exchange, @Nullable CompletableFuture<Exchange> future)	Asynchronously sends an exchange to an endpoint using a supplied Processor to populate the exchange
List<Exchange>	BrowsableEndpoint.getExchanges()	Return the exchanges available on this endpoint
default List<Exchange>	BrowsableEndpoint.getExchanges(int limit, @Nullable Predicate filter)	Return the exchanges available on this endpoint, allowing to filter the result in the specific component.

Methods in org.apache.camel.spi with parameters of type Exchange

Modifier and Type	Method	Description
@Nullable Exchange	AggregationRepository.add(CamelContext camelContext, String key, Exchange exchange)	Add the given Exchange under the correlation key.
boolean	ClaimCheckRepository.add(String key, Exchange exchange)	Adds the exchange to the repository.
default boolean	IdempotentRepository.add(Exchange exchange, String key)	Adds the key to the repository.
void	InflightRepository.add(Exchange exchange)	Adds the exchange to the inflight registry to the total counter
void	InflightRepository.add(Exchange exchange, String routeId)	Adds the exchange to the inflight registry associated to the given route
@Nullable Exchange	OptimisticLockingAggregationRepository.add(CamelContext camelContext, String key, @Nullable Exchange oldExchange, Exchange newExchange)	Add the given Exchange under the correlation key.
void	CamelInternalProcessorAdvice.after(Exchange exchange, @Nullable T data)	Callback executed after processing a step in the route.
void	ManagementInterceptStrategy.InstrumentationProcessor.after(Exchange exchange, @Nullable T data)
default void	LogListener.afterLog(Exchange exchange, CamelLogger camelLogger, String message)	Invoked right after Log component or Log EIP logs.
void	BacklogDebugger.afterProcess(Exchange exchange, Processor processor, NamedNode definition, long timeTaken)	Callback invoked after a breakpoint
void	Breakpoint.afterProcess(Exchange exchange, Processor processor, NamedNode definition, long timeTaken)	Callback invoked when the breakpoint was hit and the Exchange has been processed (after).
boolean	Debugger.afterProcess(Exchange exchange, Processor processor, NamedNode definition, long timeTaken)	Callback invoked when an Exchange has been processed which allows implementators to notify breakpoints.
void	UnitOfWork.afterProcess(Processor processor, Exchange exchange, AsyncCallback callback, boolean doneSync)	Strategy for work to be executed after the processing
void	UnitOfWork.afterRoute(Exchange exchange, Route route)	Invoked when this unit of work is done being routed by the given route.
@Nullable Object	SimpleFunction.apply(Exchange exchange, @Nullable Object input)	Applies the function to the given input
boolean	HeaderFilterStrategy.applyFilterToCamelHeaders(String headerName, @Nullable Object headerValue, Exchange exchange)	Applies filtering logic to Camel Message header that is going to be copied to target message such as CXF and JMS message.
boolean	HeaderFilterStrategy.applyFilterToExternalHeaders(String headerName, @Nullable Object headerValue, Exchange exchange)	Applies filtering logic to an external message header such as CXF and JMS message that is going to be copied to Camel message header.
CompletableFuture<Exchange>	ProducerCache.asyncSendExchange(Endpoint endpoint, ExchangePattern pattern, Processor processor, @Nullable Processor resultProcessor, @Nullable Exchange exchange, @Nullable CompletableFuture<Exchange> future)	Asynchronously sends an exchange to an endpoint using a supplied Processor to populate the exchange
@Nullable T	CamelInternalProcessorAdvice.before(Exchange exchange)	Callback executed before processing a step in the route.
@Nullable T	ManagementInterceptStrategy.InstrumentationProcessor.before(Exchange exchange)
void	SynchronizationVetoable.beforeHandover(Exchange target)	A method to perform optional housekeeping when a Synchronization is being handed over.
@Nullable org.apache.camel.util.StopWatch	BacklogDebugger.beforeProcess(Exchange exchange, Processor processor, NamedNode definition)	Callback invoked before hitting a breakpoint
void	Breakpoint.beforeProcess(Exchange exchange, Processor processor, NamedNode definition)	Callback invoked when the breakpoint was hit and the Exchange is about to be processed (before).
boolean	Debugger.beforeProcess(Exchange exchange, Processor processor, NamedNode definition)	Callback invoked when an Exchange is about to be processed which allows implementators to notify breakpoints.
AsyncCallback	UnitOfWork.beforeProcess(Processor processor, Exchange exchange, AsyncCallback callback)	Strategy for work to be executed before processing.
void	UnitOfWork.beforeRoute(Exchange exchange, Route route)	Invoked when this unit of work is about to be routed by the given route.
@Nullable StreamCache	StreamCachingStrategy.cache(Exchange exchange)	Caches the body as a StreamCache.
default boolean	IdempotentRepository.confirm(Exchange exchange, String key)	Confirms the key, after the exchange has been processed successfully.
default boolean	IdempotentRepository.contains(Exchange exchange, String key)	Returns true if this repository contains the specified element.
<T> @Nullable T	BulkTypeConverters.convertTo(Class<?> from, Class<T> to, @Nullable Exchange exchange, @Nullable Object value)	Converts the value to the specified type in the context of an exchange
default <T> @Nullable T	BulkTypeConverters.convertTo(Class<T> type, @Nullable Exchange exchange, @Nullable Object value)
CamelEvent	EventFactory.createCamelExchangeAsyncProcessingStartedEvent(Exchange exchange)	Deprecated.
UnitOfWork	UnitOfWork.createChildUnitOfWork(Exchange childExchange)	Create a child unit of work, which is associated to this unit of work as its parent.
Exchange	ProcessorExchangeFactory.createCopy(Exchange exchange)	Gets a copy of the given Exchange
Exchange	ProcessorExchangeFactory.createCorrelatedCopy(Exchange exchange, boolean handover)	Gets a copy of the given Exchange and the copy is correlated to the source
CamelEvent	EventFactory.createExchangeCompletedEvent(Exchange exchange)	Creates an CamelEvent when an Exchange has been completed successfully
CamelEvent	EventFactory.createExchangeCreatedEvent(Exchange exchange)	Creates an CamelEvent when an Exchange has been created
CamelEvent	EventFactory.createExchangeFailedEvent(Exchange exchange)	Creates an CamelEvent when an Exchange has failed
CamelEvent	EventFactory.createExchangeFailureHandledEvent(Exchange exchange, Processor failureHandler, boolean deadLetterChannel, @Nullable String deadLetterUri)	Creates an CamelEvent when an Exchange has failed but was handled by the Camel error handlers such as an dead letter channel, or a doTry .. doCatch block.
CamelEvent	EventFactory.createExchangeFailureHandlingEvent(Exchange exchange, Processor failureHandler, boolean deadLetterChannel, @Nullable String deadLetterUri)	Creates an CamelEvent when an Exchange has failed but is being handled by the Camel error handlers such as an dead letter channel, or a doTry .. doCatch block.
CamelEvent	EventFactory.createExchangeRedeliveryEvent(Exchange exchange, int attempt)	Creates an CamelEvent when an Exchange is about to be redelivered
CamelEvent	EventFactory.createExchangeSendingEvent(Exchange exchange, Endpoint endpoint)	Creates an CamelEvent when an Exchange is about to be sent to the endpoint (eg before).
CamelEvent	EventFactory.createExchangeSentEvent(Exchange exchange, Endpoint endpoint, long timeTaken)	Creates an CamelEvent when an Exchange has completely been sent to the endpoint (eg after).
@Nullable Processor	SendDynamicAware.createPostProcessor(Exchange exchange, SendDynamicAware.DynamicAwareEntry entry)	Creates an optional post Processor that will be executed afterwards when the message has been sent dynamic.
@Nullable Processor	SendDynamicAware.createPreProcessor(Exchange exchange, SendDynamicAware.DynamicAwareEntry entry)	Creates the pre Processor that will prepare the Exchange with dynamic details from the given recipient.
CamelEvent	EventFactory.createStepCompletedEvent(Exchange exchange, String stepId)	Creates an CamelEvent when a step has been completed successfully
CamelEvent	EventFactory.createStepFailedEvent(Exchange exchange, String stepId)	Creates an CamelEvent when a step has failed
CamelEvent	EventFactory.createStepStartedEvent(Exchange exchange, String stepId)	Creates an CamelEvent when a step has been started
UnitOfWork	UnitOfWorkFactory.createUnitOfWork(Exchange exchange)	Creates a new UnitOfWork
boolean	ProducerCache.AsyncProducerCallback.doInAsyncProducer(AsyncProducer asyncProducer, Exchange exchange, AsyncCallback callback)	Performs operation on the given producer to send the given exchange.
boolean	ProducerCache.doInAsyncProducer(Endpoint endpoint, Exchange exchange, AsyncCallback callback, ProducerCache.AsyncProducerCallback producerCallback)	Sends an exchange to an endpoint using a supplied callback supporting the asynchronous routing engine.
void	UnitOfWork.done(Exchange exchange)	Invoked when this unit of work has been completed, whether it has failed or completed
String	ExchangeFormatter.format(Exchange exchange)	Generates a string representation of the exchange
void	ExceptionHandler.handleException(@Nullable String message, @Nullable Exchange exchange, Throwable exception)	Handles the given exception
void	UnitOfWork.handoverSynchronization(Exchange target)	Handover all the registered synchronizations to the target Exchange.
void	UnitOfWork.handoverSynchronization(Exchange target, @Nullable Predicate<Synchronization> filter)	Handover all the registered synchronizations to the target Exchange.
void	AsyncProcessorAwaitManager.interrupt(Exchange exchange)	To interrupt an exchange which may seem as stuck, to force the exchange to continue, allowing any blocking thread to be released.
@Nullable Object	InvokeOnHeaderStrategy.invoke(Object target, String key, Exchange exchange, AsyncCallback callback)	Invoke the method based on the header key
default <T> T	BulkTypeConverters.mandatoryConvertTo(Class<?> from, Class<T> to, @Nullable Exchange exchange, @Nullable Object value)	Converts the value to the specified type in the context of an exchange
default <T> T	BulkTypeConverters.mandatoryConvertTo(Class<T> type, @Nullable Exchange exchange, @Nullable Object value)
void	DataFormat.marshal(Exchange exchange, Object graph, OutputStream stream)	Marshals the object to the given Stream.
boolean	Condition.matchEvent(Exchange exchange, CamelEvent.ExchangeEvent event)	Does the condition match
boolean	Condition.matchProcess(Exchange exchange, Processor processor, NamedNode definition, boolean before)	Does the condition match
MessageHistory	MessageHistoryFactory.newMessageHistory(String routeId, NamedNode node, Exchange exchange)	Creates a new MessageHistory
@Nullable Exception	PredicateExceptionFactory.newPredicateException(Exchange exchange, Predicate predicate, @Nullable String nodeId)	Allows to return a specific exception for the given predicate in case it failed
void	NotifyBuilderMatcher.notifyBuilderOnExchange(Exchange exchange)	When an exchange was received
void	SynchronizationRouteAware.onAfterRoute(Route route, Exchange exchange)	Invoked after the Exchange has been routed by the given route.
void	SynchronizationRouteAware.onBeforeRoute(Route route, Exchange exchange)	Invoked before the Exchange is being routed by the given route.
void	Synchronization.onComplete(Exchange exchange)	Called when the processing of the message exchange is complete
void	Breakpoint.onEvent(Exchange exchange, CamelEvent.ExchangeEvent event, @Nullable NamedNode definition)	Callback invoked when the breakpoint was hit and any of the Exchange events occurred.
boolean	Debugger.onEvent(Exchange exchange, CamelEvent.ExchangeEvent event)	Callback invoked when an Exchange is being processed which allows implementators to notify breakpoints.
void	RoutePolicy.onExchangeBegin(Route route, Exchange exchange)	Callback invoked when an Exchange is started being routed on the given Route
void	RoutePolicy.onExchangeDone(Route route, Exchange exchange)	Callback invoked when an Exchange is done being routed, where it started from the given Route
void	Synchronization.onFailure(Exchange exchange)	Called when the processing of the message exchange has failed for some reason.
String	LogListener.onLog(Exchange exchange, CamelLogger camelLogger, String message)	Invoked right before Log component or Log EIP logs.
boolean	UnitOfWork.onPrepare(Exchange exchange)	Prepares this unit of work with the given input Exchange
PollDynamicAware.DynamicAwareEntry	PollDynamicAware.prepare(Exchange exchange, String uri, String originalUri)	Prepares for using optimised dynamic polling consumer by parsing the uri and returning an entry of details.
SendDynamicAware.DynamicAwareEntry	SendDynamicAware.prepare(Exchange exchange, String uri, String originalUri)	Prepares for using optimised dynamic to by parsing the uri and returning an entry of details that are used for creating the pre- and post-processors, and the static uri.
void	AsyncProcessorAwaitManager.process(AsyncProcessor processor, Exchange exchange)	Process the given exchange synchronously.
default void	SharedInternalProcessor.process(Exchange exchange)
boolean	SharedInternalProcessor.process(Exchange exchange, AsyncCallback originalCallback, AsyncProcessor processor, @Nullable Processor resultProcessor)	Asynchronous API
void	SharedInternalProcessor.process(Exchange exchange, AsyncProcessor processor, @Nullable Processor resultProcessor)	Synchronous API
void	ClaimCheckRepository.push(Exchange exchange)	Pushes the exchange on top of the repository.
default boolean	ExchangeFactory.release(Exchange exchange)	Releases the exchange back into the pool
boolean	ProcessorExchangeFactory.release(Exchange exchange)	Releases the exchange back into the pool
void	AggregationRepository.remove(CamelContext camelContext, String key, Exchange exchange)	Removes the exchange with the given correlation key, which should happen when an Exchange is completed
default boolean	IdempotentRepository.remove(Exchange exchange, String key)	Removes the key from the repository.
void	InflightRepository.remove(Exchange exchange)	Removes the exchange from the inflight registry to the total counter
void	InflightRepository.remove(Exchange exchange, String routeId)	Removes the exchange from the inflight registry removing association to the given route
void	OptimisticLockingAggregationRepository.remove(CamelContext camelContext, String key, Exchange exchange)	Removes the given Exchange when both the supplied key and Exchange are present in the repository.
@Nullable String	PollDynamicAware.resolveStaticUri(Exchange exchange, PollDynamicAware.DynamicAwareEntry entry)	Resolves the static part of the uri that are used for creating a single Endpoint and DynamicPollingConsumer that will be reused for processing the optimised poll/pollEnrich.
@Nullable String	SendDynamicAware.resolveStaticUri(Exchange exchange, SendDynamicAware.DynamicAwareEntry entry)	Resolves the static part of the uri that are used for creating a single Endpoint and Producer that will be reused for processing the optimised toD.
Exchange	ProducerCache.send(Endpoint endpoint, Exchange exchange, @Nullable Processor resultProcessor)	Sends the exchange to the given endpoint.
boolean	BacklogTracer.shouldTrace(NamedNode node, Exchange exchange)	Whether the tracer should trace the given node and exchange (taking into account patterns and filters).
String[]	Tokenizer.tokenize(Exchange exchange)	Tokenizes the data in the provided Exchange using the current configuration options.
void	Tracer.traceAfterNode(NamedNode node, Exchange exchange)	Trace after the given node
void	Tracer.traceAfterRoute(NamedRoute route, Exchange exchange)	Trace after the route (eg output from route)
void	Tracer.traceBeforeNode(NamedNode node, Exchange exchange)	Trace before the given node
void	Tracer.traceBeforeRoute(NamedRoute route, Exchange exchange)	Trace before the route (eg input to route)
void	SyntheticBacklogTracer.traceFirstNode(NamedNode node, Exchange exchange)	Emits a synthetic first trace event (first=true, last=false) for the given node and exchange.
void	SyntheticBacklogTracer.traceLastNode(NamedNode node, Exchange exchange)	Emits a synthetic last trace event (first=false, last=true) for the given node and exchange.
void	Tracer.traceSentNode(NamedNode node, Exchange exchange, Endpoint endpoint, long elapsed)	Trace when an Exchange was sent to a given endpoint
default <T> @Nullable T	BulkTypeConverters.tryConvertTo(Class<?> from, Class<T> to, @Nullable Exchange exchange, @Nullable Object value)	Tries to convert the value to the specified type, returning null if not possible to convert.
default <T> @Nullable T	BulkTypeConverters.tryConvertTo(Class<T> type, @Nullable Exchange exchange, @Nullable Object value)
Object	DataFormat.unmarshal(Exchange exchange, InputStream stream)	Unmarshals the given stream into an object.
default Object	DataFormat.unmarshal(Exchange exchange, Object body)	Unmarshals the given body into an object.
@Nullable RestClientRequestValidator.ValidationError	RestClientRequestValidator.validate(Exchange exchange, RestClientRequestValidator.ValidationContext validationContent)	Validates the incoming client request
@Nullable RestClientResponseValidator.ValidationError	RestClientResponseValidator.validate(Exchange exchange, RestClientResponseValidator.ValidationContext validationContent)	Validates the incoming client response

Method parameters in org.apache.camel.spi with type arguments of type Exchange

Modifier and Type	Method	Description
CompletableFuture<Exchange>	ProducerCache.asyncSendExchange(Endpoint endpoint, ExchangePattern pattern, Processor processor, @Nullable Processor resultProcessor, @Nullable Exchange exchange, @Nullable CompletableFuture<Exchange> future)	Asynchronously sends an exchange to an endpoint using a supplied Processor to populate the exchange