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
-
Method Summary
Modifier and TypeMethodDescriptionvoid
declareOutputFields
(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:JmsTupleProducer
Process a JMS message object to create a Values object.- Specified by:
toTuple
in 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:JmsTupleProducer
Declare the output fields produced by this JmsTupleProducer.- Specified by:
declareOutputFields
in interfaceJmsTupleProducer
- Parameters:
declarer
- The OuputFieldsDeclarer for the spout.
-