org.apache.camel.component.mqtt
Class MQTTConfiguration

java.lang.Object
  extended by org.fusesource.mqtt.client.MQTT
      extended by org.apache.camel.component.mqtt.MQTTConfiguration

public class MQTTConfiguration
extends org.fusesource.mqtt.client.MQTT


Constructor Summary
MQTTConfiguration()
           
 
Method Summary
 int getConnectWaitInSeconds()
           
 int getDisconnectWaitInSeconds()
           
 String getMqttQosPropertyName()
           
 String getMqttRetainPropertyName()
           
 String getMqttTopicPropertyName()
           
 String getPublishTopicName()
           
 org.fusesource.mqtt.client.QoS getQoS()
           
 String getQualityOfService()
           
 int getSendWaitInSeconds()
           
 String getSubscribeTopicName()
           
 boolean isByDefaultRetain()
           
 void setByDefaultRetain(boolean byDefaultRetain)
           
 void setConnectWaitInSeconds(int connectWaitInSeconds)
           
 void setDisconnectWaitInSeconds(int disconnectWaitInSeconds)
           
 void setMqttQosPropertyName(String mqttQosPropertyName)
           
 void setMqttRetainPropertyName(String mqttRetainPropertyName)
           
 void setMqttTopicPropertyName(String mqttTopicPropertyName)
           
 void setPublishTopicName(String publishTopicName)
           
 void setQualityOfService(String qualityOfService)
           
 void setSendWaitInSeconds(int sendWaitInSeconds)
           
 void setSubscribeTopicName(String subscribeTopicName)
           
 
Methods inherited from class org.fusesource.mqtt.client.MQTT
blockingConnection, callbackConnection, futureConnection, getBlockingExecutor, getBlockingThreadPool, getClientId, getConnectAttemptsMax, getDispatchQueue, getHost, getKeepAlive, getLocalAddress, getMaxReadRate, getMaxWriteRate, getPassword, getReceiveBufferSize, getReconnectAttemptsMax, getReconnectBackOffMultiplier, getReconnectDelay, getReconnectDelayMax, getSendBufferSize, getSslContext, getTracer, getTrafficClass, getType, getUserName, getVersion, getWillMessage, getWillQos, getWillTopic, isCleanSession, isUseLocalHost, isWillRetain, setBlockingExecutor, setBlockingThreadPool, setCleanSession, setClientId, setClientId, setConnectAttemptsMax, setDispatchQueue, setHost, setHost, setHost, setKeepAlive, setLocalAddress, setLocalAddress, setMaxReadRate, setMaxWriteRate, setPassword, setPassword, setReceiveBufferSize, setReconnectAttemptsMax, setReconnectBackOffMultiplier, setReconnectDelay, setReconnectDelayMax, setSendBufferSize, setSslContext, setTracer, setTrafficClass, setUseLocalHost, setUserName, setUserName, setVersion, setWillMessage, setWillMessage, setWillQos, setWillRetain, setWillTopic, setWillTopic
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MQTTConfiguration

public MQTTConfiguration()
Method Detail

getQualityOfService

public String getQualityOfService()

setQualityOfService

public void setQualityOfService(String qualityOfService)

getQoS

public org.fusesource.mqtt.client.QoS getQoS()

getSubscribeTopicName

public String getSubscribeTopicName()

setSubscribeTopicName

public void setSubscribeTopicName(String subscribeTopicName)

getPublishTopicName

public String getPublishTopicName()

setPublishTopicName

public void setPublishTopicName(String publishTopicName)

getMqttTopicPropertyName

public String getMqttTopicPropertyName()

setMqttTopicPropertyName

public void setMqttTopicPropertyName(String mqttTopicPropertyName)

getMqttRetainPropertyName

public String getMqttRetainPropertyName()

setMqttRetainPropertyName

public void setMqttRetainPropertyName(String mqttRetainPropertyName)

getMqttQosPropertyName

public String getMqttQosPropertyName()

setMqttQosPropertyName

public void setMqttQosPropertyName(String mqttQosPropertyName)

getConnectWaitInSeconds

public int getConnectWaitInSeconds()

setConnectWaitInSeconds

public void setConnectWaitInSeconds(int connectWaitInSeconds)

getDisconnectWaitInSeconds

public int getDisconnectWaitInSeconds()

setDisconnectWaitInSeconds

public void setDisconnectWaitInSeconds(int disconnectWaitInSeconds)

getSendWaitInSeconds

public int getSendWaitInSeconds()

setSendWaitInSeconds

public void setSendWaitInSeconds(int sendWaitInSeconds)

isByDefaultRetain

public boolean isByDefaultRetain()

setByDefaultRetain

public void setByDefaultRetain(boolean byDefaultRetain)


Apache Camel