com.ibm.mq

接口 MQReceiveExit

  • 所有已知实现类:
    MQExternalReceiveExit, MQReceiveExitChain


    公共接口 MQReceiveExit
    接收出口接口允许您检查并可能更改 IBM MQ Client for Java 从队列管理器接收的数据。

    注: 以绑定方式直接连接到 IBM MQ 时,此接口不适用。

    要提供您自己的接收出口,请定义实现此接口的类。 创建类的新实例,并将其分配给 MQEnvironment.receiveExit 字段,然后再构造 MQQueueManager 对象。

    例如

      // in MyReceiveExit.java
      类 MyReceiveExit 实现 MQReceiveExit 
      {
          // 您必须提供 receiveExit 方法的实现
          public byte[] receiveExit(MQChannelExit channelExitParms,
                                    MQChannelDefinition channelDefinition,
                                    byte[] agentBuffer)
          {
              // 您的退出代码在这里 ...
          }
      }
      // 在您的主程序中 ...
      MQEnvironment.receiveExit = new MyReceiveExit();
      ... // 其他初始化
      MQQueueManager qMgr = new MQQueueManager("");
     
    • 方法详细信息

      • receiveExit

        byte[] receiveExit(MQChannelExit channelExitParms,)
                           MQChannelDefinition channelDefinition,
                           byte[] agentBuffer)
        类必须提供的接收出口方法。 每当 IBM MQ Client for Java 从队列管理器接收消息时,都会调用此消息。
        参数:
        channelExitParms -包含有关正在其中调用出口的上下文的信息。 channelExitParms.exitResponse 是一个参数,用于告知 IBM MQ Client for Java 下一步要执行的操作。
        channelDefinition -包含与队列管理器进行所有通信所通过的通道的详细信息。
        agentBuffer -包含从队列管理器接收的数据 (如果 channelExitParms.exitReason 为 MQChannelExit)。MQXR_XMIT。 否则, agentBuffer 为空。
        返回:
        要处理的数据。 如果退出响应代码(在 channelExitParms 中)是 MQXCC_OK,那么 MQ Java 客户端现在就可以处理数据了。 因此,最简单的接收出口由单行组成:

        return agentBuffer;

        另请参阅:
        MQChannelExit, MQChannelDefinition
© Copyright IBM Corp. 2008 , 2016. All Rights Reserved.