Thank you for your prompt reply.
I had tried the stomp output first but I got only empty message bodies. After some googling it looked like I needed to set a header value - "amq-msg-type" => "text". Problem is that a pull request to merge that feature in the stomp plugin was denied the previous day.
Looking through the JMS output src and underlying jruby I got it working so below is an example for any other folks looking. It actually turned out to be a simple config.
The commented lines are what did not work from the given example at the top of the src.
from output in logstash conf file:
jms {
#include_header => false
#include_properties => false
#include_body => true
#use_jms_timestamp => false
yaml_file => "/usr/local/logstash/conf.d/jms.yml"
#queue_name => "outputstomp"
destination => "outputstomp"
pub_sub => false
yaml_section => "activemq"
}
YAML file:
# Active MQ Centralized Broker
activemq:
:factory: org.apache.activemq.ActiveMQConnectionFactory
:broker_url: tcp://127.0.0.1:61616
:username: admin
:password: xxxxx
:require_jars:
- /usr/local/activemq/activemq-all-5.10.0.jar
- /usr/local/activemq/lib/optional/log4j-1.2.17.jar