[28/50] [abbrv] storm git commit: Adding cluster-test for nimbus summary storage.

[bo...@apache.org]

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/master
Commit: 63f29f349b469746fd1a4507151ec47942e03e58
Parents: 726ce80
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Thu Feb 12 16:14:14 2015 -0800
Committer: Parth Brahmbhatt <br...@gmail.com>
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)
       )))