MQ通道重啓代碼給出錯誤

Question

我寫了一些Java代碼來啓動和停止MQ通道。我在MQ上創建了一個服務器連接通道來測試此代碼。但是在執行Java代碼時，通道的啓動和停止都會產生錯誤。

停止通道給出瞭如下錯誤：

about to stop channel 
MQJE001: Completion Code 2, Reason 2202 

啓動通道提供了以下錯誤：

com.ibm.mq.MQException: MQJE001: An MQException occurred: Completion Code 2, Reason 2009 
MQJE016: MQ queue manager closed channel immediately during connect 
Closure reason = 2009 

代碼：

package com.asm.MQListenerChannelRestart; 

import com.ibm.mq.pcf.*; 
import com.ibm.mq.*; 
import com.ibm.mq.pcf.CMQCFC; 


public class MQListenerChannelRestart implements CMQCFC { 

    public void startChannel(PCFAgent pcfAgent){ 
     PCFParameter [] parameters = new PCFParameter [] { 
       new MQCFST (MQCACH_CHANNEL_NAME, "TESTChanne"), 
       new MQCFST(MQCACH_USER_ID,"user"), 
       new MQCFST(MQCACH_PASSWORD,"password") 
      }; 


     try { 

      System.out.println("about to start channel"); 
      MQMessage [] pcfResponses = pcfAgent.send (MQCMD_START_CHANNEL, 
                parameters); 

      MQCFH cfh = new MQCFH(pcfResponses[0]); 
      System.out.println("Parameter count="+cfh.parameterCount); 
      System.out.println("Reason = "+cfh.reason); 
      System.out.println(cfh.toString()); 

      pcfResponses = pcfAgent.send(MQCMD_INQUIRE_CHANNEL_STATUS, parameters); 
      cfh = new MQCFH(pcfResponses[0]); 
      System.out.println("Channel status is ==="+cfh.toString()); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 

    public void stopChannel(PCFAgent pcfAgent){ 
     PCFParameter [] parameters = new PCFParameter [] { 
       new MQCFST (MQCACH_CHANNEL_NAME, "TESTChanne"), 
       new MQCFIN (MQIACF_QUIESCE, MQQO_NO) 
       }; 


     try { 

      System.out.println("about to stop channel"); 
      MQMessage [] pcfResponses = pcfAgent.send (MQCMD_STOP_CHANNEL, 
                parameters); 

      MQCFH cfh = new MQCFH(pcfResponses[0]); 
      System.out.println("Parameter count="+cfh.parameterCount); 
      System.out.println("Reason = "+cfh.reason); 
      System.out.println(cfh.toString()); 

      pcfResponses = pcfAgent.send(MQCMD_INQUIRE_CHANNEL_STATUS, parameters); 
      cfh = new MQCFH(pcfResponses[0]); 
      System.out.println("Channel status is ==="+cfh.toString()); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 

    /** 
    * @param args 
    */ 
    public static void main(String[] args) { 
     // TODO Auto-generated method stub 

     PCFAgent pcfAgent = null; 


     MQListenerChannelRestart mqListenerChannelRestart = new MQListenerChannelRestart(); 
     mqListenerChannelRestart.stopChannel(pcfAgent); 
     mqListenerChannelRestart.startChannel(pcfAgent); 
    } 

} 

有人可以幫我解決這個問題嗎？

Answer 1

首先，您從未真正實例化過您的PCFAgent對象。

其次，您通過PCFMessageAgent將PCF命令發送到隊列管理器。 PCFMessageAgent實際上擴展了PCFAgent，所以創建一個PCFMessageAgent的對象。

第三，我不認爲來自PCFCommand的響應可以保存在MQMessage中，而是應該在PCFMessage中進行。

你應該做的是更多關於PCF讀什麼here

而且，這裏是PCF_CommonMethods這裏的一個很好的示例：ftp：// 119.44.222.58/opt/mqm/samp/pcf/samples/PCF_CommonMethods.java

截至目前你想如下面的代碼的東西：

PCFMessageAgent agent = new PCFMessageAgent ("localhost", 1414, "CLIENT"); 
PCFParameter [] parameters = new PCFParameter [] { 
      new MQCFST (MQCACH_CHANNEL_NAME, "TESTChanne"), 
      new MQCFST(MQCACH_USER_ID,"user"), 
      new MQCFST(MQCACH_PASSWORD,"password") 
     }; 

     PCFMessage request = new PCFMessage (MQCMD_START_CHANNEL,parameters); 

     PCFMessage [] responses = agent.send (request);