You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by xi...@apache.org on 2017/04/24 04:05:26 UTC
[5/5] storm git commit: Merge branch 'STORM-2349' of
https://github.com/vesense/storm
Merge branch 'STORM-2349' of https://github.com/vesense/storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3411c45e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3411c45e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3411c45e
Branch: refs/heads/master
Commit: 3411c45e9a6ef77f1e84051964ca60ac2961f951
Parents: bfd1006 ded7a1e
Author: vesense <be...@163.com>
Authored: Mon Apr 24 11:56:36 2017 +0800
Committer: vesense <be...@163.com>
Committed: Mon Apr 24 11:56:36 2017 +0800
----------------------------------------------------------------------
examples/storm-rocketmq-examples/pom.xml | 89 ++++++++
.../rocketmq/topology/WordCountTopology.java | 95 ++++++++
.../storm/rocketmq/topology/WordCounter.java | 66 ++++++
.../rocketmq/trident/WordCountTrident.java | 94 ++++++++
external/storm-mongodb/pom.xml | 2 +-
external/storm-rocketmq/README.md | 118 ++++++++++
external/storm-rocketmq/pom.xml | 71 ++++++
.../apache/storm/rocketmq/ConsumerMessage.java | 60 +++++
.../rocketmq/DefaultMessageBodySerializer.java | 37 ++++
.../rocketmq/DefaultMessageRetryManager.java | 92 ++++++++
.../storm/rocketmq/MessageBodySerializer.java | 27 +++
.../storm/rocketmq/MessageRetryManager.java | 50 +++++
.../apache/storm/rocketmq/RocketMQConfig.java | 162 ++++++++++++++
.../apache/storm/rocketmq/RocketMQUtils.java | 64 ++++++
.../org/apache/storm/rocketmq/SpoutConfig.java | 34 +++
.../storm/rocketmq/bolt/RocketMQBolt.java | 160 ++++++++++++++
.../FieldNameBasedTupleToMessageMapper.java | 66 ++++++
.../common/mapper/TupleToMessageMapper.java | 30 +++
.../common/selector/DefaultTopicSelector.java | 45 ++++
.../selector/FieldNameBasedTopicSelector.java | 63 ++++++
.../rocketmq/common/selector/TopicSelector.java | 27 +++
.../storm/rocketmq/spout/RocketMQSpout.java | 218 +++++++++++++++++++
.../rocketmq/spout/scheme/KeyValueScheme.java | 27 +++
.../spout/scheme/StringKeyValueScheme.java | 38 ++++
.../rocketmq/spout/scheme/StringScheme.java | 48 ++++
.../rocketmq/trident/state/RocketMQState.java | 117 ++++++++++
.../trident/state/RocketMQStateFactory.java | 42 ++++
.../trident/state/RocketMQStateUpdater.java | 34 +++
.../storm/rocketmq/TestMessageRetryManager.java | 106 +++++++++
pom.xml | 2 +
.../final-package/src/main/assembly/binary.xml | 7 +
31 files changed, 2090 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/3411c45e/pom.xml
----------------------------------------------------------------------
diff --cc pom.xml
index ca5890c,e0a1877..ac6928b
--- a/pom.xml
+++ b/pom.xml
@@@ -369,7 -368,9 +370,8 @@@
<module>examples/storm-mqtt-examples</module>
<module>examples/storm-pmml-examples</module>
<module>examples/storm-jms-examples</module>
+ <module>examples/storm-rocketmq-examples</module>
<module>examples/storm-perf</module>
- <module>storm-client-misc</module>
</modules>
<dependencies>