`
Xgw123485
  • 浏览: 88156 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

MQ PCF

 
阅读更多
import com.ibm.mq.*;
import com.ibm.mq.pcf.*;

try
           {
                   PCFMessageAgent agent;
                   PCFMessage  request;
                   PCFMessage []  responses;
                   // Connect a PCFAgent to the specified queue manager


                   agent = new PCFMessageAgent ("channel1");
                   System.out.println ("DEFINE CONNECTION PARMENT....");


                   //agent = new PCFMessageAgent ("xxx");
                   //远程连接的试验一直没有作通,遗憾

                   //agent = new PCFMessageAgent ("channel1");        //本地channel1 是队列管理器的名字

                   //agent = new PCFMessageAgent ("MMM");
                  // SYSTEM.DEF.SVRCONN

                   System.out.println ("Connected.");
                   agent.setCharacterSet(1381);
                   // Build the PCF request


                  /**创建队列管理器   无法创建 没有提供创建命令
                   *
                   */


                   //创建通道

                   request = new PCFMessage (CMQCFC.MQCMD_CREATE_CHANNEL);
                   request.addParameter(CMQCFC.MQCACH_CHANNEL_NAME,"mama");
                   request.addParameter(CMQCFC.MQIACH_CHANNEL_TYPE,CMQXC.MQCHT_SVRCONN);

                   //request.addParameter(CMQCFC.MQIACH_CHANNEL_INSTANCE_TYPE,CMQXC.MQXPT_TCP);


                   //创建本地队列
                   /*
                  request = new PCFMessage (CMQCFC.MQCMD_CREATE_Q);
                  request.addParameter(CMQC.MQCA_Q_NAME,"tyty");
                  request.addParameter(CMQC.MQIA_Q_TYPE,CMQC.MQQT_LOCAL);
                  */
                 //创建进程
                  /*
                  request = new PCFMessage (CMQCFC.MQCMD_CREATE_PROCESS);
                  request.addParameter(CMQC.MQCA_PROCESS_NAME,"testtd");
                  request.addParameter(CMQC.MQCA_PROCESS_DESC,"tttt");
                  */

                   // Use the agent to send the request

                   System.out.print ("Sending PCF request... ");
                   //responses =  agent.send (request);
                   //查询队列
                   /*
                        request = new PCFMessage (CMQCFC.MQCMD_INQUIRE_Q_NAMES);
                        request.addParameter (CMQC.MQCA_Q_NAME, "*");
                        request.addParameter (CMQC.MQIA_Q_TYPE, MQC.MQQT_LOCAL);
                   */
                       responses = agent.send (request);
              /*
                       String []  names = (String []) responses [0].getParameterValue (CMQCFC.MQCACF_Q_NAMES);

         for (int i = 0; i < names.length; i++)
         {
                 System.out.println ("Queue: " + names [i]);
         }
          */





                   System.out.println ("Received reply.");
                   // Disconnect
                   System.out.print ("Disconnecting... ");
                   agent.disconnect ();
                   System.out.println ("Done.");
           }

           catch (ArrayIndexOutOfBoundsException abe)
           {
                   System.out.println ("Usage: \n" +
                           "\tjava PCFMessageListQManagerAttrs queue-manager\n" +
                           "\tjava PCFMessageListQManagerAttrs host port channel");
           }

           catch (NumberFormatException nfe)
           {
                   System.out.println ("Invalid port: " + args [1]);
                   System.out.println ("Usage: \n" +
                           "\tjava PCFMessageListQManagerAttrs queue-manager\n" +
                           "\tjava PCFMessageListQManagerAttrs host port channel");
           }

           catch (PCFException pcfe)
           {
                  // System.err.println ("Error in response: ");
                   //pcfe.printStackTrace();
                   PCFMessage []  responses = (PCFMessage []) pcfe.exceptionSource;

                   for (int i = 0; i < responses.length; i++)
                   {
                           System.out.println (responses [i]);
                   }
           }

           catch (MQException mqe)
           {
                   System.err.println (mqe);
                   mqe.printStackTrace();
           }

           catch (IOException ioe)
           {
                   System.err.println (ioe);
           }

      catch(Exception e)
           {
             e.printStackTrace();
           }

分享到:
评论

相关推荐

    IBM Websphere MQ PCF 编程实例

    PCF(Platform Configuration Facility)是WebSphere MQ的一部分,它提供了与WebSphere MQ管理对象进行交互的API,使得开发人员能够通过编程方式配置、管理和监控MQ队列管理器及其组件。 在"IBM WebSphere MQ PCF ...

    IBMMQ PCF Java示例

    **IBM MQ PCF (Platform Control Facility) 是IBM提供的一个接口,用于通过编程方式与MQ队列管理器进行交互。在Java环境中,PCF允许开发者执行各种管理操作,如创建、查询和修改MQ对象,以及监控MQ队列管理器的状态...

    com.ibm.mq.pcf.jar

    ibm-mq里面的com.ibm.mq.pcf.jar下载,有需要的可以直接下载,亲自测过可以正常使用。

    监控websphere mq所需的pcf类msOb

    编号为ms0b、名称为"MQSeries Java Classes for PCF"的SupportPac,就提供了PCF的Java编程接口支持。它其中包括了用于PCF Java编程的开发包:com.ibm.mq.pcf.jar、有关PCF Java开发的说明文档以及若干示例程序。

    com.ibm.mq.pcf

    com.ibm.mq.pcf.jar java连接mq所需jar包

    pcf and mqai

    **Programmable Command Formats (PCF)** 和 **Administration Interface (MQAI)** 是 IBM WebSphere MQ 中用于管理和配置队列管理器及其相关资源的重要工具。PCF 提供了一种灵活的方式来发送命令到队列管理器,而 ...

    IBM MQ7.5_jar包

    Java连接IBM WebSphere MQ 7处理队列信息所需jar包,从安装目录.../com.ibm.mq.pcf.jar /com.ibm.mq.postcard.jar /com.ibm.mq.soap.jar /com.ibm.mq.tools.ras.jar /com.ibm.mqetclient.jar /com.ibm.mqjms.jar

    51单片机采集DS18B20、DHT11、模拟IICPCF8591采集MQ-135、OLED0.96汉字展示、ESP8266发送实时温度和控制单片机

    这篇教程主要涵盖了51单片机在环境监测与物联网应用中的综合实践,涉及了多个传感器和设备的集成,包括DS18B20温度传感器、DHT11温湿度传感器、PCF8591模拟IIC接口的ADC用于采集气体浓度、MQ-135空气质量传感器、...

    Java监控WebSphere MQ 7.5中间件信息

    2. **Program Control Facility (PCF)**:PCF是WebSphere MQ提供的一种接口,允许应用程序通过发送请求来控制和查询MQ对象。PCF消息由命令、参数和值组成,可以用来创建、修改或查询队列管理器、队列、通道等对象的...

    IBM MQ 全部JAR包

    3. **com.ibm.mq.pcf.jar**:PCF(Platform Control Facility)库提供了与MQ管理对象交互的能力,如查询和更改队列管理器的配置参数,或者管理队列和通道。 4. **com.ibm.mq.headers.jar**:这个库包含了处理MQ消息...

    java 开发 IBM WebSphere MQ 最新jar

    Java连接IBM WebSphere MQ 7处理队列信息所需jar包,从安装目录.../com.ibm.mq.pcf.jar /com.ibm.mq.postcard.jar /com.ibm.mq.soap.jar /com.ibm.mq.tools.ras.jar /com.ibm.mqetclient.jar /com.ibm.mqjms.jar ...

    IBM websphereMQ 8.0.0.5 lib

    com.ibm.mq.pcf.jar com.ibm.mq.allclient.jar com.ibm.mq.postcard.jar com.ibm.mq.axis2.jar com.ibm.mq.soap.jar com.ibm.mq.commonservices.jar com.ibm.mq.tools.ras.jar com.ibm.mq.defaultconfig.jar ...

    MQ整理jar该资源主要是用于java关联Mq中所需要的jar

    com.ibm.mq.pcf.jar com.ibm.mq.postcard.jar com.ibm.mq.soap.jar com.ibm.mq.tools.ras.jar com.ibm.mqetclient.jar com.ibm.mqjms.jar connector.jar dhbcore.jar fscontext.jar jms.jar jndi.jar jta.jar junit-...

    ibmmq所需jar包.rar

    5. **com.ibm.mq.pcf.jar**: PCF(Platform Control Facility)是IBM MQ的命令接口,允许通过编程方式执行MQ命令。此JAR提供了访问PCF命令的类,可以用来查询队列管理器的状态、设置属性等。 6. **connector.jar**:...

    ibm mq 7.5开发依赖jar包

    6. **pcf-7.5.jar**: PCF(Program Control Facility)是IBM MQ的命令框架,允许程序通过API来执行MQ命令,如查询队列状态或设置队列管理器参数。 7. **connector-7.5.jar**: 这可能是IBM MQ的连接器库,提供了与...

    java对接com.ibm.mq工具jar合集7.0.1.3.rar

    Java对接IBM MQ(Message Queuing)是企业级应用中常用的一种技术,用于实现应用程序之间的异步通信和数据交换。IBM MQ提供了一种可靠且高效的消息...此外,理解JMS和PCF的概念对于深入掌握IBM MQ的Java开发至关重要。

    ibm MQ需要的jar

    4. **com.ibm.mq.pcf.jar**:包含了处理MQ队列管理器参数配置文件(PCF,Platform Configuration Facility)的类,可用于通过编程方式管理MQ资源。 5. **com.ibm.mq.traceControl.jar**:提供了日志和跟踪功能,...

    51单片机 stm32双项目 mq-2 oled 烟雾传感器 51+PCF8591+MQ2+OLED0.96 STM32+MQ2

    文件名51+PCF8591+MQ2+OLED0.96 文件名STM32+MQ2 32是f103c8t6 三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水三点水...

    访问 IBM MQ 服务所需要jar包

    和 `com.ibm.mq.pcf.jar` 等,包含了处理MQ消息头、通用服务和队列管理命令框架的类,它们为更高级别的功能提供了基础支持。 6. **连接工厂**: 在配置MQ连接时,通常会用到`com.ibm.mq.connector.jar`,它提供了JCA...

    java 开发 IBM MQ jar包

    4. **com.ibm.mq.pcf.jar**: 提供了Program Control Facility (PCF) API,用于通过MQ命令行工具或编程方式管理MQ对象,如创建、查询和修改队列、通道等。 5. **com.ibm.mq.jms.jar**: 包含了IBM对JMS规范的实现,...

Global site tag (gtag.js) - Google Analytics