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.