Interface Channel

All Superinterfaces:

AsyncProcessor, Navigate<Processor>, Processor

public interface Channel
extends AsyncProcessor, Navigate<Processor>

Channel acts as a channel between Processors in the route graph.

The channel is responsible for routing the Exchange to the next Processor in the route graph.

Method Summary

Modifier and Type	Method	Description
Processor	getErrorHandler()	Gets the ErrorHandler this Channel uses.
Processor	getNextProcessor()	Gets the next Processor to route to (not wrapped)
Processor	getOutput()	Gets the wrapped output that at runtime should be delegated to.
Route	getRoute()	Gets the Route
void	initChannel(Route route, NamedNode definition, NamedNode childDefinition, List<InterceptStrategy> interceptors, Processor nextProcessor, NamedRoute routeDefinition, boolean first)	Initializes the channel.
void	postInitChannel()	Post initializes the channel.
void	setErrorHandler(Processor errorHandler)	Sets the ErrorHandler this Channel uses.

Methods inherited from interface AsyncProcessor

process, processAsync

Methods inherited from interface Navigate

hasNext, next

Methods inherited from interface Processor

process

Method Details

initChannel

void initChannel(Route route,
 NamedNode definition,
 NamedNode childDefinition,
 List<InterceptStrategy> interceptors,
 Processor nextProcessor,
 NamedRoute routeDefinition,
 boolean first)
          throws Exception

Initializes the channel. If the initialized output definition contained outputs (children) then the childDefinition will be set so we can leverage fine grained tracing

Throws:

Exception

postInitChannel

void postInitChannel()
              throws Exception

Post initializes the channel.

Throws:

Exception - is thrown if some error occurred

getErrorHandler

Processor getErrorHandler()

Gets the ErrorHandler this Channel uses.

Returns:

the error handler, or null if no error handler is used.

setErrorHandler

void setErrorHandler(Processor errorHandler)

Sets the ErrorHandler this Channel uses.

Parameters:

errorHandler - the error handler

getOutput

Processor getOutput()

Gets the wrapped output that at runtime should be delegated to.

Returns:

the output to route the Exchange to

getNextProcessor

Processor getNextProcessor()

Gets the next Processor to route to (not wrapped)

Returns:

the next processor

getRoute

Route getRoute()

Gets the Route

Returns:

the route context