Hello guys,
I am currently using logstash-input-jms plugin with IBM MQ 8, the pipeline is starting successfully but not picking up the message from the queue
logstash.version"=>"6.3.1"
logstash-input-jms (3.0.5)
[root@localhost ~]# logstash -f /usr/share/logstash/config/logstash.conf --path.settings /etc/logstash
Sending Logstash's logs to /var/log/logstash which is now configured via log4j2.properties
[2018-07-16T23:13:34,485][WARN ][logstash.config.source.multilocal] Ignoring the 'pipelines.yml' file because modules or command line options are specified
[2018-07-16T23:13:35,119][INFO ][logstash.runner ] Starting Logstash {"logstash.version"=>"6.3.1"}
[2018-07-16T23:13:38,227][INFO ][logstash.pipeline ] Starting pipeline {:pipeline_id=>"main", "pipeline.workers"=>2, "pipeline.batch.size"=>125, "pipeline.batch.delay"=>50}
[2018-07-16T23:13:38,423][INFO ][logstash.pipeline ] Pipeline started successfully {:pipeline_id=>"main", :thread=>"#<Thread:0xf8ec4a5 run>"}
[2018-07-16T23:13:38,568][INFO ][logstash.agent ] Pipelines running {:count=>1, :running_pipelines=>[:main], :non_running_pipelines=>[]}
[2018-07-16T23:13:39,310][INFO ][logstash.agent ] Successfully started Logstash API endpoint {:port=>9600}
/usr/share/logstash/vendor/bundle/jruby/2.3.0/gems/jruby-jms-1.2.0-java/lib/jms/connection.rb:351: warning: ambiguous Java methods found, using setExceptionListener(javax.jms.ExceptionListener)
I don't know if the current exception is causing the issue or I have a wrong configuration
My logstash.conf file:
input {
jms {
yaml_file => "/usr/share/logstash/jms/jms.yml"
yaml_section => "wmq"
include_header => true
include_properties => true
include_body => true
use_jms_timestamp => true
destination => "TO.MQ"
interval => 3
runner => async
add_field => [ "host", "computer_name" ]
}
}
output {
stdout { codec => rubydebug }
file {
path => "/usr/share/logstash/data/chris.txt"
codec => line { format => "custom format: %{message}"}
}
}
My jms.yml file :
wmq:
:factory : com.ibm.mq.jms.MQQueueConnectionFactory
:queue_manager: ELMQ
:host_name: 192.168.52.100
:channel: SYSTEM.ADMIN.SVRCONN
:port: 1414
# Transport Type: com.ibm.mq.jms.JMSC::MQJMS_TP_CLIENT_MQ_TCPIP
:transport_type: 1
:username: mqm
:require_jars:
- /usr/share/logstash/jms/jms.jar
- /usr/share/logstash/jms/com.ibm.mq.jar
- /usr/share/logstash/jms/com.ibm.mqjms.jar
- /usr/share/logstash/jms/com.ibm.mq.allclient.jar
:queue_name: FROM.MQ
:topic_name: FROM.MQ
Your assistance is highly appreciated.
Thanks,
Chris