|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.camel.impl.ServiceSupport
org.apache.camel.processor.DefaultChannel
public class DefaultChannel
DefaultChannel is the default Channel.
Channel we can in the future implement better strategies for routing the
Exchange in the route graph, as we have a Channel between each and every node
in the graph.
| Constructor Summary | |
|---|---|
DefaultChannel()
|
|
| Method Summary | |
|---|---|
void |
addInterceptStrategies(List<InterceptStrategy> strategies)
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. |
protected boolean |
continueProcessing(Exchange exchange)
Strategy to determine if we should continue processing the Exchange. |
protected void |
doStart()
|
protected void |
doStop()
|
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 |
boolean |
hasInterceptorStrategy(Class type)
|
boolean |
hasNext()
Are there more outputs? |
void |
initChannel(ProcessorDefinition outputDefinition,
RouteContext routeContext)
Initializes the channel. |
List<Processor> |
next()
Next group of outputs |
void |
process(Exchange exchange)
Processes the message exchange |
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. |
String |
toString()
|
| Methods inherited from class org.apache.camel.impl.ServiceSupport |
|---|
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Constructor Detail |
|---|
public DefaultChannel()
| Method Detail |
|---|
public List<Processor> next()
Navigate
next in interface Channelnext in interface Navigate<Processor>public boolean hasNext()
Navigate
hasNext in interface Navigate<Processor>public void setNextProcessor(Processor next)
ChannelExchange to.
setNextProcessor in interface Channelnext - the next processorpublic Processor getOutput()
Channel
getOutput in interface ChannelExchange topublic void setOutput(Processor output)
Channel
setOutput in interface Channeloutput - the output to route the Exchange topublic Processor getNextProcessor()
ChannelProcessor to route to (not wrapped)
getNextProcessor in interface Channelpublic boolean hasInterceptorStrategy(Class type)
public void setErrorHandler(Processor errorHandler)
ChannelErrorHandler this Channel uses.
setErrorHandler in interface ChannelerrorHandler - the error handlerpublic Processor getErrorHandler()
ChannelErrorHandler this Channel uses.
getErrorHandler in interface Channelpublic void addInterceptStrategy(InterceptStrategy strategy)
ChannelInterceptStrategy to apply each Exchange before
its routed to the next Processor.
addInterceptStrategy in interface Channelstrategy - the intercept strategypublic void addInterceptStrategies(List<InterceptStrategy> strategies)
ChannelInterceptStrategy to apply each Exchange before
its routed to the next Processor.
addInterceptStrategies in interface Channelstrategies - list of strategiespublic List<InterceptStrategy> getInterceptStrategies()
ChannelInterceptStrategy registered to this Channel.
getInterceptStrategies in interface Channelpublic ProcessorDefinition getProcessorDefinition()
Channel
getProcessorDefinition in interface Channel
protected void doStart()
throws Exception
doStart in class ServiceSupportException
protected void doStop()
throws Exception
doStop in class ServiceSupportException
public void initChannel(ProcessorDefinition outputDefinition,
RouteContext routeContext)
throws Exception
Channel
initChannel in interface ChanneloutputDefinition - the route defintion the Channel representsrouteContext - the route context
Exception - is thrown if some error occured
public void process(Exchange exchange)
throws Exception
Processor
process in interface Processorexchange - the message exchange
Exception - if an internal processing error has occurred.protected boolean continueProcessing(Exchange exchange)
Exchange.
public String toString()
toString in class Object
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||