Package org.apache.camel.component.nsq
Class NsqEndpoint
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.apache.camel.component.nsq.NsqEndpoint
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Endpoint
,org.apache.camel.IsSingleton
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.HasId
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
@UriEndpoint(firstVersion="2.23.0", scheme="nsq", title="NSQ", syntax="nsq:topic", category=MESSAGING) public class NsqEndpoint extends org.apache.camel.support.DefaultEndpoint
Send and receive messages from NSQ realtime distributed messaging platform.
-
-
Constructor Summary
Constructors Constructor Description NsqEndpoint(String uri, NsqComponent component, NsqConfiguration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Consumer
createConsumer(org.apache.camel.Processor processor)
ExecutorService
createExecutor()
org.apache.camel.Producer
createProducer()
NsqConfiguration
getConfiguration()
com.github.brainlag.nsq.NSQConfig
getNsqConfig()
void
setConfiguration(NsqConfiguration configuration)
-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doInit, doStart, doStop, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isSingleton, isSynchronous, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
NsqEndpoint
public NsqEndpoint(String uri, NsqComponent component, NsqConfiguration configuration)
-
-
Method Detail
-
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
- Throws:
Exception
-
createExecutor
public ExecutorService createExecutor()
-
setConfiguration
public void setConfiguration(NsqConfiguration configuration)
-
getConfiguration
public NsqConfiguration getConfiguration()
-
getNsqConfig
public com.github.brainlag.nsq.NSQConfig getNsqConfig() throws GeneralSecurityException, IOException
- Throws:
GeneralSecurityException
IOException
-
-