public class ConsulKeyValueProducer extends AbstractConsulProducer<com.orbitz.consul.KeyValueClient>
Constructor and Description |
---|
ConsulKeyValueProducer(ConsulEndpoint endpoint,
ConsulConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
deleteKey(org.apache.camel.Message message) |
protected void |
deleteKeys(org.apache.camel.Message message) |
protected void |
getKeys(org.apache.camel.Message message) |
protected void |
getSessions(org.apache.camel.Message message) |
protected void |
getValue(org.apache.camel.Message message) |
protected void |
getValues(org.apache.camel.Message message) |
protected void |
lock(org.apache.camel.Message message) |
protected void |
put(org.apache.camel.Message message) |
protected void |
unlock(org.apache.camel.Message message) |
getBody, getClient, getConfiguration, getConsul, getHeader, getKey, getMandatoryHeader, getMandatoryHeader, getMandatoryKey, getOption, isValueAsString, setBodyAndResult, setBodyAndResult, wrap
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 ConsulKeyValueProducer(ConsulEndpoint endpoint, ConsulConfiguration configuration)
protected void getValue(org.apache.camel.Message message) throws Exception
Exception
protected void getValues(org.apache.camel.Message message) throws Exception
Exception
protected void getSessions(org.apache.camel.Message message) throws Exception
Exception
protected void deleteKey(org.apache.camel.Message message) throws Exception
Exception
protected void deleteKeys(org.apache.camel.Message message) throws Exception
Exception
Apache Camel