for issue #44

Kasper Madsen · Kasper Madsen · commit d5cc24fed669 · 2012-03-19T09:37:27.000+01:00
diff --git a/src/clj/backtype/storm/LocalCluster.clj b/src/clj/backtype/storm/LocalCluster.clj
@@ -23,4 +23,20 @@
 
 (defn -killTopology [this name]
   (.killTopology (:nimbus (. this state)) name)
+  )
+
+(defn -getTopologyConf [this id]
+  (.getTopologyConf (:nimbus (. this state)) id)
+  )
+
+(defn -getTopology [this id]
+  (.getTopology (:nimbus (. this state)) id)
+  )
+
+(defn -getClusterInfo [this]
+  (.getClusterInfo (:nimbus (. this state)))
+  )
+
+(defn -getTopologyInfo [this id]
+  (.getTopologyInfo (:nimbus (. this state)) id)
   )
diff --git a/src/jvm/backtype/storm/ILocalCluster.java b/src/jvm/backtype/storm/ILocalCluster.java
@@ -1,9 +1,12 @@
 package backtype.storm;
 
 import backtype.storm.generated.AlreadyAliveException;
+import backtype.storm.generated.ClusterSummary;
 import backtype.storm.generated.InvalidTopologyException;
 import backtype.storm.generated.NotAliveException;
 import backtype.storm.generated.StormTopology;
+import backtype.storm.generated.TopologyInfo;
+
 import java.util.Map;
 
 
@@ -13,4 +16,8 @@ void submitTopology(String topologyName, Map conf, StormTopology topology)
     void killTopology(String topologyName)
             throws NotAliveException;
     void shutdown();
+    String getTopologyConf(String id);
+    StormTopology getTopology(String id);
+    ClusterSummary getClusterInfo();
+    TopologyInfo getTopologyInfo(String id);
 }
