org.apache.camel.component.routebox.strategy
Class RouteboxDispatcher

java.lang.Object
  org.apache.camel.component.routebox.strategy.RouteboxDispatcher

public class RouteboxDispatcher
extends Object

Constructor Summary

RouteboxDispatcher(org.apache.camel.ProducerTemplate producer)

Method Summary

org.apache.camel.Exchange	dispatchAsync(RouteboxEndpoint endpoint, org.apache.camel.Exchange exchange)
org.apache.camel.Exchange	dispatchSync(RouteboxEndpoint endpoint, org.apache.camel.Exchange exchange)
protected List<URI>	getInnerContextConsumerList(org.apache.camel.CamelContext context)
org.apache.camel.Exchange	issueRequest(org.apache.camel.Endpoint endpoint, org.apache.camel.ExchangePattern pattern, Object body, Map<String,Object> headers)
protected URI	selectDispatchUri(RouteboxEndpoint endpoint, org.apache.camel.Exchange exchange)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RouteboxDispatcher

public RouteboxDispatcher(org.apache.camel.ProducerTemplate producer)

Method Detail

dispatchSync

public org.apache.camel.Exchange dispatchSync(RouteboxEndpoint endpoint,
                                              org.apache.camel.Exchange exchange)
                                       throws Exception

Throws:

Exception

dispatchAsync

public org.apache.camel.Exchange dispatchAsync(RouteboxEndpoint endpoint,
                                               org.apache.camel.Exchange exchange)
                                        throws Exception

Throws:

Exception

selectDispatchUri

protected URI selectDispatchUri(RouteboxEndpoint endpoint,
                                org.apache.camel.Exchange exchange)
                         throws Exception

Throws:

Exception

getInnerContextConsumerList

protected List<URI> getInnerContextConsumerList(org.apache.camel.CamelContext context)
                                         throws URISyntaxException

Throws:

URISyntaxException

issueRequest

public org.apache.camel.Exchange issueRequest(org.apache.camel.Endpoint endpoint,
                                              org.apache.camel.ExchangePattern pattern,
                                              Object body,
                                              Map<String,Object> headers)
                                       throws org.apache.camel.CamelExecutionException

Throws:

org.apache.camel.CamelExecutionException