Class JsonTupleProducer

java.lang.Object
org.apache.storm.jms.example.JsonTupleProducer
All Implemented Interfaces:
Serializable, JmsTupleProducer

public class JsonTupleProducer extends Object implements JmsTupleProducer
A simple JmsTupleProducer that expects to receive JMS TextMessage objects with a body in JSON format.

Ouputs a tuple with field name "json" and a string value containing the raw json.

NOTE: Currently this implementation assumes the text is valid JSON and does not attempt to parse or validate it.

Author:
tgoetz
See Also:
  • Constructor Details

    • JsonTupleProducer

      public JsonTupleProducer()
  • Method Details

    • toTuple

      public Values toTuple(javax.jms.Message msg) throws javax.jms.JMSException
      Description copied from interface: JmsTupleProducer
      Process a JMS message object to create a Values object.
      Specified by:
      toTuple in interface JmsTupleProducer
      Parameters:
      msg - - the JMS message
      Returns:
      the Values tuple, or null if the message couldn't be processed.
      Throws:
      javax.jms.JMSException
    • declareOutputFields

      public void declareOutputFields(OutputFieldsDeclarer declarer)
      Description copied from interface: JmsTupleProducer
      Declare the output fields produced by this JmsTupleProducer.
      Specified by:
      declareOutputFields in interface JmsTupleProducer
      Parameters:
      declarer - The OuputFieldsDeclarer for the spout.