org.thales.punch.libraries.storm.bolt

Class HttpNode

java.lang.Object

org.thales.punch.libraries.storm.api.BaseProcessingNode

org.thales.punch.libraries.storm.bolt.HttpNode

All Implemented Interfaces:

Serializable, org.apache.storm.task.IBolt, org.apache.storm.topology.IComponent, org.apache.storm.topology.IRichBolt

public class HttpNode
extends org.thales.punch.libraries.storm.api.BaseProcessingNode

Send http request for each tuple. WARNING: SEND POST ONLY and subcribe on default field "log"

 
 {
  "bolts": [
    {
      "type": "http_output",
      "bolt_settings": {
        "url": "http://domain.com/request"
      },
      "storm_settings": {
        "component": "http_bolt",
        "subscribe": [
        ....
       ]
      }
    }
  ]
 }
 

Author:

romain

See Also:

Serialized Form

Field Summary

Fields inherited from class org.thales.punch.libraries.storm.api.BaseProcessingNode

ackRate, collector, componentId, every, failRate, metricContext, nodeSettings, topologyContext, traversalTime

Constructor Summary

Constructors

Constructor and Description
HttpNode(org.thales.punch.libraries.storm.api.NodeSettings boltSettings)

Method Summary

Modifier and Type	Method and Description
void	prepare(Map stormConf, org.apache.storm.task.TopologyContext context, org.apache.storm.task.OutputCollector collector)
void	process(org.apache.storm.tuple.Tuple input)

Methods inherited from class org.thales.punch.libraries.storm.api.BaseProcessingNode

ack, cleanup, declareOutputFields, enrichAndForwardMonitoringTuple, execute, fail, getComponentConfiguration, getNewPoint

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpNode

public HttpNode(org.thales.punch.libraries.storm.api.NodeSettings boltSettings)

Method Detail

prepare

public void prepare(Map stormConf,
                    org.apache.storm.task.TopologyContext context,
                    org.apache.storm.task.OutputCollector collector)

Specified by:

prepare in interface org.apache.storm.task.IBolt

Overrides:

prepare in class org.thales.punch.libraries.storm.api.BaseProcessingNode

process

public void process(org.apache.storm.tuple.Tuple input)

Specified by:

process in class org.thales.punch.libraries.storm.api.BaseProcessingNode