Ibm mq 독립형 서버를 통한 연결]

Question

독립형 서버를 통해 ibm mq 대기열에 연결하려고합니다. (전 7.0.3 ibmmq 항아리를 사용하고 있습니다)

cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, "dcc"); 
      cf.setIntProperty(WMQConstants.WMQ_PORT, 14321); 
      cf.setStringProperty(WMQConstants.WMQ_CHANNEL, "dfds"); 
      cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT); 
      cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, "dw"); 
      cf.setStringProperty(WMQConstants.USERID, "ww"); 
      cf.setStringProperty(WMQConstants.PASSWORD, "vw"); 

내가 연결 팩토리의 모든 속성을 설정했습니다. 회의가 성공적으로 완료되었지만 대기열을 열 수 없습니다. 다음 오류가 발생합니다.

**MQJE001: Completion Code '2', Reason '6114'.** 
FAILED: Queueconnection 
com.ibm.msg.client.jms.DetailedJMSException: JMSWMQ2008: Failed to open MQ queue 'US.0732931.NGEN.MANIFEST.LOADS'. 
JMS attempted to perform an MQOPEN, but WebSphere MQ reported an error. 
Use the linked exception to determine the cause of this error. Check that the specified queue and queue manager are defined correctly. 
    at com.ibm.msg.client.wmq.common.internal.Reason.reasonToException(Reason.java:585) 
    at com.ibm.msg.client.wmq.common.internal.Reason.createException(Reason.java:221) 

Answer 1

정말 충분한 정보를 제공하지 않습니다.

• 어떤 연결 팩토리를 사용하고 있습니까?
• 오류는 MQOPEN에서 발생하지만 당신은 중요한

여기에 샘플 코드의 당신의 createQueue 방법에 대한 코드 표시하지 않음 :

private void putMessage() 
{ 
    JmsConnectionFactory cf = null; 
    Connection connection = null; 
    Session session = null; 
    Destination reqQ = null; 
    MessageProducer producer = null; 

    try 
    { 
     // Create a connection factory 
     JmsFactoryFactory ff = JmsFactoryFactory.getInstance(WMQConstants.WMQ_PROVIDER); 

     cf = ff.createConnectionFactory(); 
     cf.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, "MY_QMGR_NAME"); 
     cf.setStringProperty(WMQConstants.WMQ_CHANNEL, "MY_TEST_CHL"); 
     cf.setStringProperty(WMQConstants.WMQ_HOST_NAME, "some_remote_server"); 
     cf.setIntProperty(WMQConstants.WMQ_PORT, 1414); 
     cf.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT); 
     cf.setStringProperty(WMQConstants.USERID, "my_uid"); 
     cf.setStringProperty(WMQConstants.PASSWORD, "my_pwd"); 

     // Create JMS objects 
     connection = cf.createConnection(); 
     connection.start(); 
     session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 

     /** 
     * Create destination to send requests 
     * - MQA1 is the queue manager name 
     * - TEST.Q1 is the queue name 
     */ 
     reqQ = session.createQueue("queue://MQA1/TEST.Q1"); 

     // Create producer 
     producer = session.createProducer(reqQ); 
     // Create a message 
     Message myMsg = session.createTextMessage("This is a test message."); 
     // Send it 
     producer.send(myMsg); 
    } 
    catch(Exception ex) 
    { 
     System.err.println(ex.getLocalizedMessage()); 
    } 
    finally 
    { 
     try 
     { 
     session.close(); 
     } 
     catch (Exception ex) 
     { 
     System.err.println("session.close() : " + ex.getLocalizedMessage()); 
     } 

     try 
     { 
     connection.close(); 
     } 
     catch (Exception ex) 
     { 
     System.err.println("connection.close() : " + ex.getLocalizedMessage()); 
     } 
    } 
}