Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

logstash-input-jms, connect to websphere MQ 8 #24

Closed
ghost opened this issue Nov 8, 2017 · 1 comment
Closed

logstash-input-jms, connect to websphere MQ 8 #24

ghost opened this issue Nov 8, 2017 · 1 comment

Comments

@ghost
Copy link

ghost commented Nov 8, 2017

hello,
version logstash: 5.6.2
os: windows 8
websphere mq: 8.0.0.4
elasticsearch: 5.5.2

guys i create test queue as describe in #21

my logstash_jms.conf

input {
    jms {
        yaml_file => "C:/distr/logstash-5.6.2/jms/jms.yml"
        yaml_section => "wmq"
        include_header => true
        include_properties => true
        include_body => true
        use_jms_timestamp => true
        destination => "TEST.LOG"
        interval => 3
        runner => async
        add_field => [ "host", "computer_name" ]
    }
}


output {
   elasticsearch {
      hosts => ["192.168.0.171:9200"]
      index => "bus-%{+YYYY.MM.dd}"  
   }
}

and jms.yml

# IBM WebSphere MQ
wmq:
    :factory: com.ibm.mq.jms.MQQueueConnectionFactory
    :queue_manager: QMTEST
    :host_name: localhost
    :channel: LOGSTASH.CHL
    :port: 1414
    # Transport Type: com.ibm.mq.jms.JMSC::MQJMS_TP_CLIENT_MQ_TCPIP
    :transport_type: 1
    :username: User
    :require_jars:
        - "C:/distr/logstash-5.6.2/jms/jms-1.0.2b.jar"
        - "C:/distr/logstash-5.6.2/jms/com.ibm.mq.jar"
        - "C:/distr/logstash-5.6.2/jms/com.ibm.mqjms.jar"
        - "C:/distr/logstash-5.6.2/jms/com.ibm.mq.allclient.jar"

i disabled autorization of queue manager with : alter qmgr chlauth(disabled)

i try to use in username param: PS-NB1\User and User@PS-NB1
this use is in group mqm

in host_name i try to use localhost, ip-address(it's not problem)

but when i start logstash, i got exception as:
in short: incorrect authentification data for queue manager


[2017-11-08T19:13:04,280][WARN ][logstash.inputs.jms      ] JMS Consumer died {:
exception=>com.ibm.msg.client.jms.DetailedJMSSecurityException: JMSWMQ2013: Неве
рные данные аутентификации предоставлены администратору очередей QueueManager 'Q
MTEST' в режиме соединения 'Client' с помощью хоста 'localhost(1414)'.
Проверьте правильность предоставленных имени пользователя и пароля в администрат
оре очередей, с которым устанавливается соединение., :backtrace=>["com.ibm.msg.c
lient.wmq.common.internal.Reason.reasonToException(com/ibm/msg/client/wmq/common
/internal/Reason.java:531)", "com.ibm.msg.client.wmq.common.internal.Reason.crea
teException(com/ibm/msg/client/wmq/common/internal/Reason.java:215)", "com.ibm.m
sg.client.wmq.internal.WMQConnection.<init>(com/ibm/msg/client/wmq/internal/WMQC
onnection.java:413)", "com.ibm.msg.client.wmq.factories.WMQConnectionFactory.cre
ateV7ProviderConnection(com/ibm/msg/client/wmq/factories/WMQConnectionFactory.ja
va:8475)", "com.ibm.msg.client.wmq.factories.WMQConnectionFactory.createProvider
Connection(com/ibm/msg/client/wmq/factories/WMQConnectionFactory.java:7814)", "c
om.ibm.msg.client.jms.admin.JmsConnectionFactoryImpl._createConnection(com/ibm/m
sg/client/jms/admin/JmsConnectionFactoryImpl.java:299)", "com.ibm.msg.client.jms
.admin.JmsConnectionFactoryImpl.createConnection(com/ibm/msg/client/jms/admin/Jm
sConnectionFactoryImpl.java:236)", "com.ibm.mq.jms.MQConnectionFactory.createCom
monConnection(com/ibm/mq/jms/MQConnectionFactory.java:6024)", "com.ibm.mq.jms.MQ
QueueConnectionFactory.createQueueConnection(com/ibm/mq/jms/MQQueueConnectionFac
tory.java:111)", "com.ibm.mq.jms.MQQueueConnectionFactory.createConnection(com/i
bm/mq/jms/MQQueueConnectionFactory.java:187)", "java.lang.reflect.Method.invoke(
java/lang/reflect/Method.java:498)", "RUBY.initialize(c:/distr/logstash-5.6.2/ve
ndor/bundle/jruby/1.9/gems/jruby-jms-1.2.0-java/lib/jms/connection.rb:204)", "RU
BY.start(c:/distr/logstash-5.6.2/vendor/bundle/jruby/1.9/gems/jruby-jms-1.2.0-ja
va/lib/jms/connection.rb:50)", "RUBY.run_async(c:/distr/logstash-5.6.2/vendor/bu
ndle/jruby/1.9/gems/logstash-input-jms-3.0.4-java/lib/logstash/inputs/jms.rb:228
)", "RUBY.run(c:/distr/logstash-5.6.2/vendor/bundle/jruby/1.9/gems/logstash-inpu
t-jms-3.0.4-java/lib/logstash/inputs/jms.rb:259)", "RUBY.inputworker(c:/distr/lo
gstash-5.6.2/logstash-core/lib/logstash/pipeline.rb:472)", "RUBY.start_input(c:/
distr/logstash-5.6.2/logstash-core/lib/logstash/pipeline.rb:465)", "java.lang.Th
read.run(java/lang/Thread.java:748)"]}
/distr/logstash-5.6.2/logstash-core/lib/logstash/pipeline.rb:472)", "RUBY.start_
input(c:/distr/logstash-5.6.2/logstash-core/lib/logstash/pipeline.rb:465)", "jav
a.lang.Thread.run(java/lang/Thread.java:748)"]}

please give me advice, what do i incorrect?

@ghost
Copy link
Author

ghost commented Nov 9, 2017

guys, i solved problem.
i disabled auth mode in queue manager as describe in note:
https://www.ibm.com/developerworks/community/blogs/messaging/entry/getting_going_without_turning_off_mq_security?lang=en
4 : ALTER QMGR CHLAUTH(DISABLED) CONNAUTH(' ')
AMQ8005: Администратор очередей WebSphere MQ изменен.
REFRESH SECURITY TYPE(CONNAUTH)
5 : REFRESH SECURITY TYPE(CONNAUTH)
then logstash cann connect to queue and read messages

@ghost ghost closed this as completed Nov 9, 2017
This issue was closed.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

0 participants