public class JsonTupleProducer extends Object implements JmsTupleProducer
A simple JmsTupleProducer that expects to receive JMS TextMessage objects with a body in JSON format.
| Constructor and Description |
|---|
JsonTupleProducer() |
| Modifier and Type | Method and Description |
|---|---|
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output fields produced by this JmsTupleProducer.
|
Values |
toTuple(javax.jms.Message msg)
Process a JMS message object to create a Values object.
|
public Values toTuple(javax.jms.Message msg) throws javax.jms.JMSException
JmsTupleProducerProcess a JMS message object to create a Values object.
toTuple in interface JmsTupleProducermsg - javax.jms.JMSExceptionpublic void declareOutputFields(OutputFieldsDeclarer declarer)
JmsTupleProducerDeclare the output fields produced by this JmsTupleProducer.
declareOutputFields in interface JmsTupleProducerdeclarer - The OuputFieldsDeclarer for the spout.Copyright © 2021 The Apache Software Foundation. All rights reserved.