Permalink
Browse files

make 0.7.0 compatible

  • Loading branch information...
1 parent d513517 commit 8f83e201cade2b604a02225fdb86eca5e6239d86 @nathanmarz committed May 31, 2012
Showing with 6 additions and 3 deletions.
  1. +2 −2 project.clj
  2. +4 −1 src/jvm/backtype/storm/spout/KestrelThriftSpout.java
View
@@ -1,9 +1,9 @@
-(defproject storm/storm-kestrel "0.7.2-SNAPSHOT"
+(defproject storm/storm-kestrel "0.7.2-snap2"
:source-path "src/clj"
:java-source-path "src/jvm"
:javac-options {:debug "true" :fork "true"}
:dependencies []
- :dev-dependencies [[storm "0.7.1"]
+ :dev-dependencies [[storm "0.7.0"]
[org.clojure/clojure "1.2.0"]
[org.clojure/clojure-contrib "1.2.0"]]
:jvm-opts ["-Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib"]
@@ -1,5 +1,6 @@
package backtype.storm.spout;
+import backtype.storm.Config;
import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.topology.base.BaseRichSpout;
@@ -121,7 +122,9 @@ public Fields getOutputFields() {
int _messageTimeoutMillis;
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
- _messageTimeoutMillis = 1000 * context.maxTopologyMessageTimeout();
+ //TODO: should switch this to maxTopologyMessageTimeout
+ Number timeout = (Number) conf.get(Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS);
+ _messageTimeoutMillis = 1000 * timeout.intValue();
_collector = collector;
_emitIndex = 0;
_kestrels = new ArrayList<KestrelClientInfo>();

0 comments on commit 8f83e20

Please sign in to comment.