@UriEndpoint(firstVersion="2.19.0", scheme="pubnub", title="PubNub", syntax="pubnub:channel", consumerClass=PubNubConsumer.class, label="cloud,iot,messaging") public class PubNubEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
PubNubEndpoint(String uri,
PubNubComponent component,
PubNubConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
PubNubConfiguration |
getConfiguration() |
com.pubnub.api.PubNub |
getPubnub()
Reference to a Pubnub client in the registry.
|
boolean |
isSingleton() |
void |
setPubnub(com.pubnub.api.PubNub pubnub) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, 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 PubNubEndpoint(String uri, PubNubComponent component, PubNubConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public PubNubConfiguration getConfiguration()
public com.pubnub.api.PubNub getPubnub()
public void setPubnub(com.pubnub.api.PubNub pubnub)
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
Apache Camel