VoIP Knowledge Base sip-voip-completion Initial commit 202004291431HEADmaster

1 files changed, 40 insertions, 0 deletions

diff --git a/src/main/java/cn/ac/iie/bolt/FromSpoutBufferBoltDC.java b/src/main/java/cn/ac/iie/bolt/FromSpoutBufferBoltDC.java
new file mode 100644
index 0000000..4b82597
--- /dev/null
+++ b/src/main/java/cn/ac/iie/bolt/FromSpoutBufferBoltDC.java
@@ -0,0 +1,40 @@
+package cn.ac.iie.bolt;
+
+
+import org.apache.log4j.Logger;
+import org.apache.storm.task.TopologyContext;
+import org.apache.storm.topology.BasicOutputCollector;
+import org.apache.storm.topology.OutputFieldsDeclarer;
+import org.apache.storm.topology.base.BaseBasicBolt;
+import org.apache.storm.tuple.Fields;
+import org.apache.storm.tuple.Tuple;
+import org.apache.storm.tuple.Values;
+
+import java.util.Map;
+
+public class FromSpoutBufferBoltDC extends BaseBasicBolt {
+    private static final long serialVersionUID = -106783017834081712L;
+
+    private static Logger logger = Logger.getLogger(FromSpoutBufferBoltDC.class);
+
+    @Override
+    public void prepare(Map stormConf, TopologyContext context) {
+    }
+
+    @Override
+    public void execute(Tuple tuple, BasicOutputCollector collector) {
+        try {
+            collector.emit(new Values(tuple.getString(0)));
+        } catch (Exception e) {
+            logger.error("FromSpoutBufferBoltDC Get Log is error --->" + e);
+            e.printStackTrace();
+        }
+
+    }
+
+    @Override
+    public void declareOutputFields(OutputFieldsDeclarer declarer) {
+        declarer.declare(new Fields("json"));
+    }
+
+}