Package org.apache.storm.jms.example
Class JsonTupleProducer
java.lang.Object
org.apache.storm.jms.example.JsonTupleProducer
- All Implemented Interfaces:
Serializable,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 Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) Declare the output fields produced by this JmsTupleProducer.toTuple(javax.jms.Message msg) Process a JMS message object to create a Values object.
-
Constructor Details
-
JsonTupleProducer
public JsonTupleProducer()
-
-
Method Details
-
toTuple
Description copied from interface:JmsTupleProducerProcess a JMS message object to create a Values object.- Specified by:
toTuplein interfaceJmsTupleProducer- Parameters:
msg- - the JMS message- Returns:
- the Values tuple, or null if the message couldn't be processed.
- Throws:
javax.jms.JMSException
-
declareOutputFields
Description copied from interface:JmsTupleProducerDeclare the output fields produced by this JmsTupleProducer.- Specified by:
declareOutputFieldsin interfaceJmsTupleProducer- Parameters:
declarer- The OuputFieldsDeclarer for the spout.
-