diff options
| author | Prabeesh K <prabsmails@gmail.com> | 2014-01-10 09:33:31 +0530 |
|---|---|---|
| committer | Prabeesh K <prabsmails@gmail.com> | 2014-01-10 09:33:31 +0530 |
| commit | 645f5e83ee38a329332850bf44ea67b0711a705c (patch) | |
| tree | ab07578f94e6d705263b4a6b38d83061bff635a7 /external/mqtt | |
| parent | 4b074fac054848ebd3397a3cce0a3e7871d3860c (diff) | |
| download | spark-645f5e83ee38a329332850bf44ea67b0711a705c.tar.gz spark-645f5e83ee38a329332850bf44ea67b0711a705c.tar.bz2 spark-645f5e83ee38a329332850bf44ea67b0711a705c.zip | |
Change clientId to random clientId
Returns a randomly generated client identifier based on the current user's login name and the system time.
Diffstat (limited to 'external/mqtt')
| -rw-r--r-- | external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala b/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala index c8987a3ee0..41e813d48c 100644 --- a/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala +++ b/external/mqtt/src/main/scala/org/apache/spark/streaming/mqtt/MQTTInputDStream.scala @@ -80,7 +80,7 @@ class MQTTReceiver(brokerUrl: String, var peristance: MqttClientPersistence = new MemoryPersistence() // Initializing Mqtt Client specifying brokerUrl, clientID and MqttClientPersistance - var client: MqttClient = new MqttClient(brokerUrl, "MQTTSub", peristance) + var client: MqttClient = new MqttClient(brokerUrl, MqttClient.generateClientId(), peristance) // Connect to MqttBroker client.connect() |