@UriEndpoint(firstVersion="2.16.0", 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() |
String |
getPassword() |
PahoPersistence |
getPersistence() |
int |
getQos() |
String |
getTopic() |
String |
getUserName() |
boolean |
isAutoReconnect() |
boolean |
isResolveMqttConnectOptions() |
boolean |
isRetained() |
boolean |
isSingleton() |
protected org.eclipse.paho.client.mqttv3.MqttConnectOptions |
resolveMqttConnectOptions() |
protected org.eclipse.paho.client.mqttv3.MqttClientPersistence |
resolvePersistence() |
void |
setAutoReconnect(boolean autoReconnect)
Client will automatically attempt to reconnect to the server if the connection is lost
|
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 |
setPassword(String password)
Password to be used for authentication against the MQTT broker
|
void |
setPersistence(PahoPersistence persistence)
Client persistence to be used - memory or file.
|
void |
setQos(int qos)
Client quality of service level (0-2).
|
void |
setResolveMqttConnectOptions(boolean resolveMqttConnectOptions)
Define if you don't want to resolve the MQTT Connect Options from registry
|
void |
setRetained(boolean retained)
Retain option
|
void |
setTopic(String topic)
Name of the topic
|
void |
setUserName(String userName)
Username to be used for authentication against the MQTT broker
|
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)
public boolean isAutoReconnect()
public void setAutoReconnect(boolean autoReconnect)
autoReconnect
- public String getUserName()
public void setUserName(String userName)
userName
- public String getPassword()
public void setPassword(String password)
password
- public boolean isResolveMqttConnectOptions()
public void setResolveMqttConnectOptions(boolean resolveMqttConnectOptions)
resolveMqttConnectOptions
- Apache Camel