public class RibbonServiceCallProcessor
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.AsyncProcessor, org.apache.camel.CamelContextAware, org.apache.camel.Traceable, org.apache.camel.spi.IdAware
Constructor and Description |
---|
RibbonServiceCallProcessor(String name,
String uri,
String scheme,
org.apache.camel.ExchangePattern exchangePattern,
RibbonConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.CamelContext |
getCamelContext() |
String |
getId() |
com.netflix.loadbalancer.IPing |
getPing() |
Map<String,String> |
getRibbonClientConfig() |
com.netflix.loadbalancer.IRule |
getRule() |
org.apache.camel.spi.ServiceCallServerListStrategy |
getServerListStrategy() |
String |
getTraceLabel() |
void |
process(org.apache.camel.Exchange exchange) |
boolean |
process(org.apache.camel.Exchange exchange,
org.apache.camel.AsyncCallback callback) |
void |
setCamelContext(org.apache.camel.CamelContext camelContext) |
void |
setId(String id) |
void |
setPing(com.netflix.loadbalancer.IPing ping) |
void |
setRibbonClientConfig(Map<String,String> ribbonClientConfig) |
void |
setRule(com.netflix.loadbalancer.IRule rule) |
void |
setServerListStrategy(org.apache.camel.spi.ServiceCallServerListStrategy serverListStrategy) |
public RibbonServiceCallProcessor(String name, String uri, String scheme, org.apache.camel.ExchangePattern exchangePattern, RibbonConfiguration configuration)
public void process(org.apache.camel.Exchange exchange) throws Exception
process
in interface org.apache.camel.Processor
Exception
public boolean process(org.apache.camel.Exchange exchange, org.apache.camel.AsyncCallback callback)
process
in interface org.apache.camel.AsyncProcessor
public org.apache.camel.CamelContext getCamelContext()
getCamelContext
in interface org.apache.camel.CamelContextAware
public void setCamelContext(org.apache.camel.CamelContext camelContext)
setCamelContext
in interface org.apache.camel.CamelContextAware
public String getId()
getId
in interface org.apache.camel.spi.HasId
public void setId(String id)
setId
in interface org.apache.camel.spi.IdAware
public String getTraceLabel()
getTraceLabel
in interface org.apache.camel.Traceable
public org.apache.camel.spi.ServiceCallServerListStrategy getServerListStrategy()
public void setServerListStrategy(org.apache.camel.spi.ServiceCallServerListStrategy serverListStrategy)
public com.netflix.loadbalancer.IRule getRule()
public void setRule(com.netflix.loadbalancer.IRule rule)
public com.netflix.loadbalancer.IPing getPing()
public void setPing(com.netflix.loadbalancer.IPing ping)
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
Apache Camel