public abstract class AbstractConsulProducer<C>
extends org.apache.camel.impl.HeaderSelectorProducer
Modifier | Constructor and Description |
---|---|
protected |
AbstractConsulProducer(ConsulEndpoint endpoint,
ConsulConfiguration configuration,
Function<com.orbitz.consul.Consul,C> clientSupplier) |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
getBody(org.apache.camel.Message message,
T defaultValue,
Class<T> type) |
protected C |
getClient() |
protected ConsulConfiguration |
getConfiguration() |
protected com.orbitz.consul.Consul |
getConsul() |
protected <D> D |
getHeader(org.apache.camel.Message message,
String header,
D defaultValue,
Class<D> type) |
protected String |
getKey(org.apache.camel.Message message) |
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 String |
getMandatoryKey(org.apache.camel.Message message) |
protected <T> T |
getOption(org.apache.camel.Message message,
T defaultValue,
Class<T> type) |
protected boolean |
isValueAsString(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
protected AbstractConsulProducer(ConsulEndpoint endpoint, ConsulConfiguration configuration, Function<com.orbitz.consul.Consul,C> clientSupplier)
protected ConsulConfiguration getConfiguration()
protected <D> D getHeader(org.apache.camel.Message message, String header, D defaultValue, Class<D> type)
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 String getKey(org.apache.camel.Message message)
protected String getMandatoryKey(org.apache.camel.Message message) throws Exception
Exception
protected <T> T getOption(org.apache.camel.Message message, T defaultValue, Class<T> type)
protected boolean isValueAsString(org.apache.camel.Message message) throws Exception
Exception
protected <T> T getBody(org.apache.camel.Message message, T defaultValue, Class<T> type) 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