-
Notifications
You must be signed in to change notification settings - Fork 1.7k
/
utils_test.clj
28 lines (27 loc) · 1.13 KB
/
utils_test.clj
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
(ns backtype.storm.utils-test
(:import [backtype.storm Config])
(:import [backtype.storm.utils Utils])
(:import [com.netflix.curator.retry ExponentialBackoffRetry])
(:use [backtype.storm util])
(:use [clojure test])
)
(deftest test-new-curator-uses-exponential-backoff
(let [expected_interval 2400
expected_retries 10
expected_ceiling (/ expected_interval 2)
conf (merge (clojurify-structure (Utils/readDefaultConfig))
{Config/STORM_ZOOKEEPER_RETRY_INTERVAL expected_interval
Config/STORM_ZOOKEEPER_RETRY_TIMES expected_retries
Config/STORM_ZOOKEEPER_RETRY_INTERVAL_CEILING expected_ceiling})
servers ["bogus_server"]
arbitrary_port 42
curator (Utils/newCurator conf servers arbitrary_port)
retry (-> curator .getZookeeperClient .getRetryPolicy)
]
(is (.isAssignableFrom ExponentialBackoffRetry (.getClass retry)))
(is (= (.getBaseSleepTimeMs retry) expected_interval))
(is (= (.getN retry) expected_retries))
(is (= (.getMaxRetryInterval retry) expected_ceiling))
(is (= (.getSleepTimeMs retry 10 0) expected_ceiling))
)
)