Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

removed unnecessary KestrelAdder class

  • Loading branch information...
commit 24486aa7294ec49aae4660fac432e5d5c8cb2af3 1 parent ea92355
@nathanmarz authored
Showing with 2 additions and 33 deletions.
  1. +2 −2 project.clj
  2. +0 −31 src/jvm/backtype/storm/drpc/KestrelAdder.java
View
4 project.clj
@@ -1,7 +1,7 @@
-(defproject storm/storm-kestrel "0.5.1-SNAPSHOT"
+(defproject storm/storm-kestrel "0.5.4"
:java-source-path "src/jvm"
:javac-options {:debug "true" :fork "true"}
:dependencies []
- :dev-dependencies [[storm "0.5.0"]]
+ :dev-dependencies [[storm "0.5.4"]]
:jvm-opts ["-Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib"]
)
View
31 src/jvm/backtype/storm/drpc/KestrelAdder.java
@@ -1,31 +0,0 @@
-package backtype.storm.drpc;
-
-import backtype.storm.spout.KestrelClient;
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
-import org.json.simple.JSONValue;
-
-
-public class KestrelAdder implements SpoutAdder {
- KestrelClient _client;
-
- public KestrelAdder(String host, String port) {
- try {
- _client = new KestrelClient(host, Integer.parseInt(port));
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
- }
-
- public void add(String function, String jsonArgs, String returnInfo) {
- Map val = new HashMap();
- val.put("args", jsonArgs);
- val.put("return", returnInfo);
- try {
- _client.queue(function, JSONValue.toJSONString(val));
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
-}
Please sign in to comment.
Something went wrong with that request. Please try again.