Java-клиент, использующий JMS для подключения к каналу IBM MQ с ошибкой выбрасывания TCP / IP - PullRequest
Новая
       27

Java-клиент, использующий JMS для подключения к каналу IBM MQ с ошибкой выбрасывания TCP / IP

2 голосов
/ 11 июля 2019

У нас есть IBM MQ Server 7.5, работающий на компьютере с Windows. До сих пор у нас был клиент IBM MQ JMS (написанный на groovy) в Windows для чтения сообщений по каналу TCP.

Моя проблема сейчас в том, что мы должны переместить Клиента на компьютер Debian. Я скачал IBM MQ Client 7 для Debian.

Я пишу пример кода для подключения к Серверу для чтения сообщений. Я использую пример JmsPutGet.java с сайта IBM.

Среда выглядит следующим образом:

  1. Java 8
  2. com.ibm.mq.allclient-9.0.4.0.jar
  3. javax.jms-api-2.0.1

Я получаю ошибку 

The value specified for the property is not supported.
Modify the value to be within the range of accepted values.
FAILURE

Я также пытался использовать режим подключения Client, он выдает другую ошибку, как показано ниже: 

com.ibm.msg.client.jms.DetailedJMSException: JMSWMQ0018: Failed to connect to queue manager 'VIMSRRI10' with connection mode 'Client' and host name '172.18.21.5(1415)'.
Check the queue manager is started and if running in client mode, check there is a listener running. Please see the linked exception for more information.
Inner exception(s):
com.ibm.mq.MQException: JMSCMQ0001: IBM MQ call failed with compcode '2' ('MQCC_FAILED') reason '2539' ('MQRC_CHANNEL_CONFIG_ERROR').
com.ibm.mq.jmqi.JmqiException: CC=2;RC=2539;AMQ9204: Connection to host '172.18.21.5(1415)' rejected. [1=com.ibm.mq.jmqi.JmqiException[CC=2;RC=2539;AMQ9547: Type of remote channel not suitable for action requested. [3=IRRICI10.VIMSRRI10]],3=172.18.21.5(1415),5=RemoteConnection.analyseErrorSegment]
com.ibm.mq.jmqi.JmqiException: CC=2;RC=2539;AMQ9547: Type of remote channel not suitable for action requested. [3=IRRICI10.VIMSRRI10]
FAILURE

Пример кода Java: 

JmsFactoryFactory ff =  JmsFactoryFactory.getInstance(WMQConstants.WMQ_PROVIDER);
JmsConnectionFactory cf = ff.createConnectionFactory();

// Set the properties
cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, HOST);
cf.setIntProperty(WMQConstants.WMQ_PORT, PORT);
cf.setStringProperty(WMQConstants.WMQ_CHANNEL, CHANNEL);
cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_DIRECT_TCPIP);
cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, QMGR);
cf.setStringProperty(WMQConstants.WMQ_APPLICATIONNAME, "JmsPutGet (JMS)");
//cf.setBooleanProperty(WMQConstants.USER_AUTHENTICATION_MQCSP, true);
//cf.setStringProperty(WMQConstants.USERID, APP_USER);
//cf.setStringProperty(WMQConstants.PASSWORD, APP_PASSWORD);

// Create JMS objects
context = cf.createContext();
System.out.println("After Context\n");
destination = context.createQueue("queue:///" + QUEUE_NAME);
System.out.println("After Queue\n");
long uniqueNumber = System.currentTimeMillis() % 1000;
TextMessage message = context.createTextMessage("Your lucky number today is " + uniqueNumber);

producer = context.createProducer();
producer.send(destination, message);
System.out.println("Sent message:\n" + message);

consumer = context.createConsumer(destination); // autoclosable
String receivedMessage = consumer.receiveBody(String.class, 15000); // in ms or 15 seconds

System.out.println("\nReceived message:\n" + receivedMessage);

1 Ответ

3 голосов
/ 11 июля 2019

Канал, к которому вы подключаетесь, должен быть SVRCONN.

Ошибка reason '2539' ('MQRC_CHANNEL_CONFIG_ERROR') указывает, что канал, к которому вы подключаетесь, не является SVRCONN.

Это разъясняется в следующей строке ошибки, в которой также указывается название канала, к которому вы пытаетесь подключиться IRRICI10.VIMSRRI10: 

AMQ9547: Type of remote channel not suitable for action requested. [3=IRRICI10.VIMSRRI10]

Название самого канала имеет формат, общий для каналов SDR или RCVR, которые используются между двумя администраторами очередей, а не для подключения клиентского приложения MQ.

...