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 <lrese...@apache.org> Authored: Wed Jul 19 18:24:04 2017 -0700 Committer: Luciano Resende <lrese...@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:
