Issue using logstash-input-jms with IBM MQ 8

(Christian Abi Khalil) #1

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-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
[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 :

:factory :
:queue_manager: ELMQ
:port: 1414
# Transport Type:
:transport_type: 1
:username: mqm
- /usr/share/logstash/jms/jms.jar
- /usr/share/logstash/jms/
- /usr/share/logstash/jms/
- /usr/share/logstash/jms/
:queue_name: FROM.MQ
:topic_name: FROM.MQ

Your assistance is highly appreciated.


(system) #2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.