public class PahoComponent
extends org.apache.camel.impl.UriEndpointComponent
Constructor and Description |
---|
PahoComponent() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
String |
getBrokerUrl() |
String |
getClientId() |
org.eclipse.paho.client.mqttv3.MqttConnectOptions |
getConnectOptions() |
void |
setBrokerUrl(String brokerUrl)
The URL of the MQTT broker.
|
void |
setClientId(String clientId)
MQTT client identifier.
|
void |
setConnectOptions(org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions)
Client connection options
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, doStart, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public String getBrokerUrl()
public void setBrokerUrl(String brokerUrl)
public String getClientId()
public void setClientId(String clientId)
public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectOptions()
public void setConnectOptions(org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions)
Apache Camel