public final class ConsulCatalogProducer
extends org.apache.camel.impl.HeaderSelectorProducer
Constructor and Description |
---|
ConsulCatalogProducer(ConsulEndpoint endpoint,
ConsulConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected com.orbitz.consul.option.QueryOptions |
buildQueryOptions(org.apache.camel.Message message,
ConsulConfiguration conf) |
protected void |
deregister(org.apache.camel.Message message) |
protected C |
getClient() |
protected ConsulConfiguration |
getConfiguration() |
protected <D> D |
getMandatoryHeader(org.apache.camel.Message message,
String header,
Class<D> type) |
protected <D> D |
getMandatoryHeader(org.apache.camel.Message message,
String header,
D defaultValue,
Class<D> type) |
protected void |
getNode(org.apache.camel.Message message) |
protected void |
getService(org.apache.camel.Message message) |
protected void |
listDatacenters(org.apache.camel.Message message) |
protected void |
listNodes(org.apache.camel.Message message) |
protected void |
listServices(org.apache.camel.Message message) |
protected <T> void |
processConsulResponse(org.apache.camel.Message message,
com.orbitz.consul.model.ConsulResponse<T> response) |
protected void |
register(org.apache.camel.Message message) |
protected void |
setBodyAndResult(org.apache.camel.Message message,
Object body) |
protected void |
setBodyAndResult(org.apache.camel.Message message,
Object body,
boolean result) |
protected org.apache.camel.Processor |
wrap(Function<C,Object> supplier) |
bind, doStart, getProcessor, onMissingProcessor
createExchange, createExchange, createExchange, doStop, getEndpoint, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public ConsulCatalogProducer(ConsulEndpoint endpoint, ConsulConfiguration configuration)
protected void register(org.apache.camel.Message message) throws Exception
Exception
protected void deregister(org.apache.camel.Message message) throws Exception
Exception
protected void listDatacenters(org.apache.camel.Message message) throws Exception
Exception
protected void listNodes(org.apache.camel.Message message) throws Exception
Exception
protected void listServices(org.apache.camel.Message message) throws Exception
Exception
protected void getService(org.apache.camel.Message message) throws Exception
Exception
protected ConsulConfiguration getConfiguration()
protected <D> D getMandatoryHeader(org.apache.camel.Message message, String header, Class<D> type) throws Exception
Exception
protected <D> D getMandatoryHeader(org.apache.camel.Message message, String header, D defaultValue, Class<D> type) throws Exception
Exception
protected com.orbitz.consul.option.QueryOptions buildQueryOptions(org.apache.camel.Message message, ConsulConfiguration conf)
protected <T> void processConsulResponse(org.apache.camel.Message message, com.orbitz.consul.model.ConsulResponse<T> response) throws Exception
Exception
protected void setBodyAndResult(org.apache.camel.Message message, Object body) throws Exception
Exception
protected void setBodyAndResult(org.apache.camel.Message message, Object body, boolean result) throws Exception
Exception
Apache Camel