@UriEndpoint(firstVersion="2.17.0", scheme="nats", title="Nats", syntax="nats:servers", label="messaging", consumerClass=NatsConsumer.class) public class NatsEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
NatsEndpoint(String uri,
NatsComponent component,
NatsConfiguration config) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
ExecutorService |
createExecutor() |
org.apache.camel.Producer |
createProducer() |
io.nats.client.Connection |
getConnection() |
NatsConfiguration |
getNatsConfiguration() |
boolean |
isSingleton() |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public NatsEndpoint(String uri, NatsComponent component, NatsConfiguration config)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public ExecutorService createExecutor()
public boolean isSingleton()
public NatsConfiguration getNatsConfiguration()
public io.nats.client.Connection getConnection() throws InterruptedException, IllegalArgumentException, GeneralSecurityException, IOException
Apache Camel