@UriEndpoint(firstVersion="2.23.0", scheme="nsq", title="NSQ", syntax="nsq:servers", consumerClass=NsqConsumer.class, label="messaging") public class NsqEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
NsqEndpoint(String uri,
NsqComponent component,
NsqConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
ExecutorService |
createExecutor() |
org.apache.camel.Producer |
createProducer() |
com.github.brainlag.nsq.NSQConfig |
getNsqConfig() |
NsqConfiguration |
getNsqConfiguration() |
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 NsqEndpoint(String uri, NsqComponent component, NsqConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public ExecutorService createExecutor()
public boolean isSingleton()
public NsqConfiguration getNsqConfiguration()
public com.github.brainlag.nsq.NSQConfig getNsqConfig() throws GeneralSecurityException, IOException
GeneralSecurityException
IOException
Apache Camel