@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() |
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, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic NatsEndpoint(String uri, NatsComponent component, NatsConfiguration config)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
Exceptionpublic ExecutorService createExecutor()
public boolean isSingleton()
public NatsConfiguration getNatsConfiguration()
Apache Camel