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/09 15:48:16 UTC
[11/32] git commit: STORM-297: remove param thread-name when we know
we are consuming from a disruptor queue,
just use queue name as thread name will suffice
STORM-297: remove param thread-name when we know we are consuming from a disruptor queue, just use queue name as thread name will suffice
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/6b9da080
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/6b9da080
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/6b9da080
Branch: refs/heads/master
Commit: 6b9da0804e59935bbe280570bead20954e779c40
Parents: 19e72e8
Author: Sean Zhong <cl...@gmail.com>
Authored: Tue May 20 11:32:20 2014 +0800
Committer: Sean Zhong <cl...@gmail.com>
Committed: Tue May 20 11:32:20 2014 +0800
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/disruptor.clj | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/6b9da080/storm-core/src/clj/backtype/storm/disruptor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/disruptor.clj b/storm-core/src/clj/backtype/storm/disruptor.clj
index 28393eb..a199055 100644
--- a/storm-core/src/clj/backtype/storm/disruptor.clj
+++ b/storm-core/src/clj/backtype/storm/disruptor.clj
@@ -83,8 +83,7 @@
(defn halt-with-interrupt! [^DisruptorQueue queue]
(.haltWithInterrupt queue))
-(defnk consume-loop* [^DisruptorQueue queue handler :kill-fn (fn [error] (halt-process! 1 "Async loop died!"))
- :thread-name nil]
+(defnk consume-loop* [^DisruptorQueue queue handler :kill-fn (fn [error] (halt-process! 1 "Async loop died!"))]
(let [ret (async-loop
(fn []
(consume-batch-when-available queue handler)
@@ -98,5 +97,5 @@
(defmacro consume-loop [queue & handler-args]
`(let [handler# (handler ~@handler-args)]
- (consume-loop* ~queue handler# :thread-name (.getName queue))
+ (consume-loop* ~queue handler#)
))