September 2017
Beginner to intermediate
360 pages
8h 13m
English
This bolt is used to generate an alert in the form of an SMS using the Twilio application. Also, emit tuples so that it can be saved into Elasticsearch:
package com.book.processing;import java.io.BufferedReader;import java.io.InputStreamReader;import java.math.BigDecimal;import java.math.RoundingMode;import java.util.Map;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 com.book.domain.AlertEvent;import com.hazelcast.client.HazelcastClient;import com.hazelcast.client.config.ClientConfig; ...
Read now
Unlock full access