You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/06/06 18:46:55 UTC
[2/6] git commit: Minor improvement
Minor improvement
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/4a8fc69c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/4a8fc69c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/4a8fc69c
Branch: refs/heads/master
Commit: 4a8fc69c8276bf1de6a293411f889d9b97636d94
Parents: 4c61cd4
Author: Kyle Nusbaum <kn...@yahoo-inc.com>
Authored: Mon Jun 2 22:11:54 2014 +0000
Committer: Kyle Nusbaum <kn...@yahoo-inc.com>
Committed: Mon Jun 2 22:11:54 2014 +0000
----------------------------------------------------------------------
storm-core/test/clj/backtype/storm/drpc_test.clj | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/4a8fc69c/storm-core/test/clj/backtype/storm/drpc_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/drpc_test.clj b/storm-core/test/clj/backtype/storm/drpc_test.clj
index 312ec23..6251a3a 100644
--- a/storm-core/test/clj/backtype/storm/drpc_test.clj
+++ b/storm-core/test/clj/backtype/storm/drpc_test.clj
@@ -221,12 +221,12 @@
(.shutdown drpc)
))
-(deftest test-drpc-timeout-cleanup
- (is (thrown? DRPCExecutionException
- (let [queue (ConcurrentLinkedQueue.)
- delay-seconds 2]
- (stubbing [acquire-queue queue
- read-storm-config {DRPC-REQUEST-TIMEOUT-SECS delay-seconds}]
- (let [drpc-handler (service-handler)]
+(deftest test-drpc-timeout-cleanup
+ (let [queue (ConcurrentLinkedQueue.)
+ delay-seconds 2]
+ (stubbing [acquire-queue queue
+ read-storm-config {DRPC-REQUEST-TIMEOUT-SECS delay-seconds}]
+ (let [drpc-handler (service-handler)]
+ (is (thrown? DRPCExecutionException
(.execute drpc-handler "ArbitraryDRPCFunctionName" "no-args")))))))