Adding cluster-test for nimbus summary storage.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/63f29f34 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/63f29f34 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/63f29f34 Branch: refs/heads/0.11.x-branch Commit: 63f29f349b469746fd1a4507151ec47942e03e58 Parents: 726ce80 Author: Parth Brahmbhatt <[email protected]> Authored: Thu Feb 12 16:14:14 2015 -0800 Committer: Parth Brahmbhatt <[email protected]> Committed: Thu Feb 12 16:14:14 2015 -0800 ---------------------------------------------------------------------- storm-core/test/clj/backtype/storm/cluster_test.clj | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/63f29f34/storm-core/test/clj/backtype/storm/cluster_test.clj ---------------------------------------------------------------------- diff --git a/storm-core/test/clj/backtype/storm/cluster_test.clj b/storm-core/test/clj/backtype/storm/cluster_test.clj index b7630b1..85aaf3b 100644 --- a/storm-core/test/clj/backtype/storm/cluster_test.clj +++ b/storm-core/test/clj/backtype/storm/cluster_test.clj @@ -213,6 +213,12 @@ (.remove-storm! state "storm1") (is (= [] (.code-distributor state nil))) + (is (= [] (.nimbuses state))) + (.add-nimbus-host! state "host:port" nimbusInfo1) + (is (= [nimbusInfo1] (.nimbuses state))) + (.add-nimbus-host! state "host1:port" nimbusInfo2) + (is (= #{nimbusInfo1 nimbusInfo2} (set (.nimbuses state)))) + ;; TODO add tests for task info and task heartbeat setting and getting (.disconnect state) )))
