|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
public interface Channel
Channel acts as a channel between Processors in the route graph.
Exchange to the next Processor in the route graph.
| Method Summary | |
|---|---|
void |
addInterceptStrategies(List<InterceptStrategy> strategy)
Adds a list of InterceptStrategy to apply each Exchange before
its routed to the next Processor. |
void |
addInterceptStrategy(InterceptStrategy strategy)
Adds a InterceptStrategy to apply each Exchange before
its routed to the next Processor. |
Processor |
getErrorHandler()
Gets the ErrorHandler this Channel uses. |
List<InterceptStrategy> |
getInterceptStrategies()
Gets the list of InterceptStrategy registered to this Channel. |
Processor |
getNextProcessor()
Gets the next Processor to route to (not wrapped) |
Processor |
getOutput()
Gets the wrapped output that at runtime should be delegated to. |
ProcessorDefinition |
getProcessorDefinition()
Gets the defintion of the next processor |
void |
initChannel(ProcessorDefinition outputDefinition,
RouteContext routeContext)
Initializes the channel. |
List<Processor> |
next()
Next group of outputs |
void |
setErrorHandler(Processor errorHandler)
Sets the ErrorHandler this Channel uses. |
void |
setNextProcessor(Processor next)
Sets the processor that the channel should route the Exchange to. |
void |
setOutput(Processor output)
Sets the wrapped output that at runtime should be delegated to. |
| Methods inherited from interface org.apache.camel.Processor |
|---|
process |
| Methods inherited from interface org.apache.camel.Navigate |
|---|
hasNext |
| Method Detail |
|---|
List<Processor> next()
Navigate
next in interface Navigate<Processor>void setNextProcessor(Processor next)
Exchange to.
next - the next processorvoid setErrorHandler(Processor errorHandler)
ErrorHandler this Channel uses.
errorHandler - the error handlerProcessor getErrorHandler()
ErrorHandler this Channel uses.
void addInterceptStrategy(InterceptStrategy strategy)
InterceptStrategy to apply each Exchange before
its routed to the next Processor.
strategy - the intercept strategyvoid addInterceptStrategies(List<InterceptStrategy> strategy)
InterceptStrategy to apply each Exchange before
its routed to the next Processor.
strategy - list of strategiesList<InterceptStrategy> getInterceptStrategies()
InterceptStrategy registered to this Channel.
void initChannel(ProcessorDefinition outputDefinition,
RouteContext routeContext)
throws Exception
outputDefinition - the route defintion the Channel representsrouteContext - the route context
Exception - is thrown if some error occuredProcessor getOutput()
Exchange tovoid setOutput(Processor output)
output - the output to route the Exchange toProcessor getNextProcessor()
Processor to route to (not wrapped)
ProcessorDefinition getProcessorDefinition()
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||