Skip to content
Snippets Groups Projects
Commit 975f53e4 authored by Prabeesh K's avatar Prabeesh K Committed by Reynold Xin
Browse files

[minor][streaming]fixed scala string interpolation error

Author: Prabeesh K <prabeesh.k@namshi.com>

Closes #5653 from prabeesh/fix and squashes the following commits:

9d7a9f5 [Prabeesh K] fixed scala string interpolation error
parent a7d65d38
No related branches found
No related tags found
No related merge requests found
......@@ -56,7 +56,7 @@ object MQTTPublisher {
while (true) {
try {
msgtopic.publish(message)
println(s"Published data. topic: {msgtopic.getName()}; Message: {message}")
println(s"Published data. topic: ${msgtopic.getName()}; Message: $message")
} catch {
case e: MqttException if e.getReasonCode == MqttException.REASON_CODE_MAX_INFLIGHT =>
Thread.sleep(10)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment