You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/01/25 00:29:38 UTC
[30/50] storm git commit: Merge branch 'storm-mqtt' of
github.com:ptgoetz/storm
Merge branch 'storm-mqtt' of github.com:ptgoetz/storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4cf77c58
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4cf77c58
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4cf77c58
Branch: refs/heads/1.x-branch
Commit: 4cf77c5876d2ca3103f7fcc9ec092962527b780a
Parents: 686ffd6 9768587
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Jan 20 17:07:29 2016 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Jan 20 17:07:29 2016 -0500
----------------------------------------------------------------------
external/storm-mqtt/README.md | 375 +++++++++++++++++++
external/storm-mqtt/core/pom.xml | 126 +++++++
.../java/org/apache/storm/mqtt/MqttLogger.java | 36 ++
.../java/org/apache/storm/mqtt/MqttMessage.java | 41 ++
.../apache/storm/mqtt/MqttMessageMapper.java | 44 +++
.../org/apache/storm/mqtt/MqttTupleMapper.java | 37 ++
.../org/apache/storm/mqtt/bolt/MqttBolt.java | 107 ++++++
.../apache/storm/mqtt/common/MqttOptions.java | 334 +++++++++++++++++
.../apache/storm/mqtt/common/MqttPublisher.java | 67 ++++
.../org/apache/storm/mqtt/common/MqttUtils.java | 88 +++++
.../org/apache/storm/mqtt/common/SslUtils.java | 64 ++++
.../mqtt/mappers/ByteArrayMessageMapper.java | 34 ++
.../storm/mqtt/mappers/StringMessageMapper.java | 37 ++
.../apache/storm/mqtt/spout/AckableMessage.java | 71 ++++
.../org/apache/storm/mqtt/spout/MqttSpout.java | 262 +++++++++++++
.../storm/mqtt/ssl/DefaultKeyStoreLoader.java | 97 +++++
.../apache/storm/mqtt/ssl/KeyStoreLoader.java | 35 ++
.../storm/mqtt/trident/MqttPublishFunction.java | 85 +++++
.../storm/mqtt/StormMqttIntegrationTest.java | 152 ++++++++
external/storm-mqtt/examples/pom.xml | 116 ++++++
.../examples/src/main/flux/sample.yaml | 62 +++
.../examples/src/main/flux/ssl-sample.yaml | 78 ++++
.../mqtt/examples/CustomMessageMapper.java | 49 +++
.../mqtt/examples/MqttBrokerPublisher.java | 102 +++++
.../examples/src/main/resources/log4j2.xml | 32 ++
external/storm-mqtt/pom.xml | 58 +++
pom.xml | 1 +
storm-dist/binary/src/main/assembly/binary.xml | 22 ++
28 files changed, 2612 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/4cf77c58/pom.xml
----------------------------------------------------------------------