@UriEndpoint(scheme="paho", title="Paho", consumerClass=PahoConsumer.class, label="messaging,iot", syntax="paho:topic") public class PahoEndpoint extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
PahoEndpoint(String uri,
String topic,
org.apache.camel.Component component) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage,
String topic) |
org.apache.camel.Producer |
createProducer() |
protected void |
doStart() |
protected void |
doStop() |
String |
getBrokerUrl() |
org.eclipse.paho.client.mqttv3.MqttClient |
getClient() |
String |
getClientId() |
PahoComponent |
getComponent() |
org.eclipse.paho.client.mqttv3.MqttConnectOptions |
getConnectOptions() |
String |
getFilePersistenceDirectory() |
PahoPersistence |
getPersistence() |
int |
getQos() |
String |
getTopic() |
boolean |
isRetained() |
boolean |
isSingleton() |
protected org.eclipse.paho.client.mqttv3.MqttConnectOptions |
resolveMqttConnectOptions() |
protected org.eclipse.paho.client.mqttv3.MqttClientPersistence |
resolvePersistence() |
void |
setBrokerUrl(String brokerUrl)
The URL of the MQTT broker.
|
void |
setClient(org.eclipse.paho.client.mqttv3.MqttClient client)
To use the existing MqttClient instance as client.
|
void |
setClientId(String clientId)
MQTT client identifier.
|
void |
setConnectOptions(org.eclipse.paho.client.mqttv3.MqttConnectOptions connOpts)
Client connection options
|
void |
setFilePersistenceDirectory(String filePersistenceDirectory)
Base directory used by the file persistence provider.
|
void |
setPersistence(PahoPersistence persistence)
Client persistence to be used - memory or file.
|
void |
setQos(int qos)
Client quality of service level (0-2).
|
void |
setRetained(boolean retained)
Retain option
|
void |
setTopic(String topic)
Name of the topic
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, 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
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public PahoComponent getComponent()
getComponent
in class org.apache.camel.impl.DefaultEndpoint
protected org.eclipse.paho.client.mqttv3.MqttClientPersistence resolvePersistence()
protected org.eclipse.paho.client.mqttv3.MqttConnectOptions resolveMqttConnectOptions()
public org.apache.camel.Exchange createExchange(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage, String topic)
public String getClientId()
public void setClientId(String clientId)
public String getBrokerUrl()
public void setBrokerUrl(String brokerUrl)
public String getTopic()
public void setTopic(String topic)
public int getQos()
public void setQos(int qos)
public boolean isRetained()
public void setRetained(boolean retained)
retained
- true/falsepublic PahoPersistence getPersistence()
public void setPersistence(PahoPersistence persistence)
public String getFilePersistenceDirectory()
public void setFilePersistenceDirectory(String filePersistenceDirectory)
public org.eclipse.paho.client.mqttv3.MqttClient getClient()
public void setClient(org.eclipse.paho.client.mqttv3.MqttClient client)
public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectOptions()
public void setConnectOptions(org.eclipse.paho.client.mqttv3.MqttConnectOptions connOpts)
Apache Camel