I'm developing a product with Logstash + Elasticsearch + Kibana.
I needed to make Logstash listen a JMS queue and I made it using JMS Input Plugin.
I needed to convert the xml to json and I made it using JMS XML filter plugin.
- Now I need to query elasticsearch based on an id I receveid on my input message
- Consume a rest service based on an id received from the elasticsearch query
- Merge the content of elasticsearch result, input message and rest service responses and update the elasticsearch record.
Can I perform all these remaining steps only with logstash? If so, which plugins(filters/codecs) should I use? If not, any ideas of how to do it?
I really appreciate any help