I'm currently doing json serialize/deserialize using gson-2.3 on storm-0.9.2-incubating and it seems to be working fine.
On Wed, Nov 5, 2014 at 5:18 PM, Yuheng Du <[email protected]> wrote: > Does anyone implemented a JSON serialization scheme for Strom version >= > 0.9.0? > > On Wed, Nov 5, 2014 at 2:24 PM, Yuheng Du <[email protected]> wrote: > >> Hi guys, >> >> I am using rabbitmq-spout offered by >> https://github.com/ppat/storm-rabbitmq to read data from rabbitmq. Here >> is what I see in the console when I run the topology locally: >> >> 101703 [Thread-16-storm-obser-spout] INFO backtype.storm.daemon.executor >> - Acking message 33 >> 113099 [Thread-16-storm-obser-spout] INFO backtype.storm.daemon.task - >> Emitting: storm-obser-spout default >> [{"readings":[0.0,0.0,0.0,88.007,0.0,0.0,0.0,17.83,64.0,0.0,0.0,0.0,0.0,11.071,0.2,1.69,0.0,0.0,-0.23,88.007,0.0,0.0,0.0,0.0,0.0,0.0],"observationId":"f45ef06f-88dc-4d50-b28e-24937dda5240","deploymentId":" >> http://www.xxxx.org/resource/deployment#aiken_8","deviceId":"0","observationDateTime":"11-05-2014 >> 19:05:15 UTC"}, >> io.latent.storm.rabbitmq.RabbitMQMessageScheme$Envelope@2a8ec790, >> io.latent.storm.rabbitmq.RabbitMQMessageScheme$Properties@3cfd4c4] >> 113099 [Thread-16-storm-obser-spout] INFO backtype.storm.daemon.task - >> Emitting: storm-obser-spout __ack_init [-3424274568001459772 0 2] >> >> Can anybody tell me where does these two lines come from: >> "io.latent.storm.rabbitmq.RabbitMQMessageScheme$Envelope@2a8ec790, >> io.latent.storm.rabbitmq.RabbitMQMessageScheme$Properties@3cfd4c4" ? >> >> How can I parse each field in my JSON format messages like "readings" and >> "observationDateTime"? >> >> I attached my topology source code. >> >> Thanks. >> >> >
