You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2017/07/20 01:24:08 UTC
bahir git commit: [MINOR] Fix copy+paste typo
Repository: bahir
Updated Branches:
refs/heads/master e3d9e6960 -> 0d9725d4c
[MINOR] Fix copy+paste typo
Project: http://git-wip-us.apache.org/repos/asf/bahir/repo
Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/0d9725d4
Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/0d9725d4
Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/0d9725d4
Branch: refs/heads/master
Commit: 0d9725d4ccc315760ecc35eeeb25c58a15258b3a
Parents: e3d9e69
Author: Luciano Resende <lr...@apache.org>
Authored: Wed Jul 19 18:24:04 2017 -0700
Committer: Luciano Resende <lr...@apache.org>
Committed: Wed Jul 19 18:24:04 2017 -0700
----------------------------------------------------------------------
streaming-mqtt/README.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/bahir/blob/0d9725d4/streaming-mqtt/README.md
----------------------------------------------------------------------
diff --git a/streaming-mqtt/README.md b/streaming-mqtt/README.md
index eb08b51..5117594 100644
--- a/streaming-mqtt/README.md
+++ b/streaming-mqtt/README.md
@@ -52,7 +52,7 @@ this actor can be configured to handle failures, etc.
val lines = MQTTUtils.createStream(ssc, brokerUrl, topic)
val lines = MQTTUtils.createPairedStream(ssc, brokerUrl, topic)
- val lines = MQTTUtils.createPairedByteArrayStreamStream(ssc, brokerUrl, topic)
+ val lines = MQTTUtils.createPairedByteArrayStream(ssc, brokerUrl, topic)
Additional mqtt connection options can be provided: