com.ibm.mq

类 MQQueue

    • 方法详细信息

      • putForward消息

        public void putForward消息 (MQMessage 消息)
                       抛出 MQException，
                              java.io.IOException
        使用缺省 put 消息选项和消息作为原始消息，将正在转发的消息放入队列
        参数：
        message -要转发
        抛出：
        MQException -如果 MQI 调用失败
        java.io.IOException -如果存在 IO 错误

      • putForward消息

        public void putForward消息 (MQMessage 消息，
                              MQPutMessage选项 putMessage选项)
                       抛出 MQException，
                              java.io.IOException
        使用消息作为原始消息将正在转发的消息放入队列
        参数：
        message -要转发
        putMessageOptions -用于 MQPUT
        抛出：
        MQException -如果 MQI 调用失败
        java.io.IOException -如果存在 IO 错误

      • putReply消息

        public void putReply消息 (MQMessage 消息)
                     抛出 MQException，
                            java.io.IOException
        使用缺省 put 消息选项和消息作为原始消息将应答消息放入队列
        参数：
        message --原始消息。
        抛出：
        MQException -如果 MQ 调用失败
        java.io.IOException -如果存在 IO 错误

      • putReply消息

        public void putReply消息 (MQMessage 消息，
                            MQPutMessage选项 putMessage选项)
                     抛出 MQException，
                            java.io.IOException
        使用消息作为原始消息将应答消息放入队列
        参数：
        message --原始消息。
        putMessageOptions -用于 MQPUT。
        抛出：
        MQException -如果 MQ 调用失败
        java.io.IOException -如果存在 IO 错误

      • putReport消息

        public void putReport消息 (MQMessage 消息)
                      抛出 MQException，
                             java.io.IOException
        使用缺省 put 消息选项和消息作为原始消息将报告消息放入队列
        参数：
        message --原始消息。
        抛出：
        MQException -如果 MQ 调用失败
        java.io.IOException -如果存在 IO 错误

      • putReport消息

        public void putReport消息 (MQMessage 消息，
                             MQPutMessage选项 putMessage选项)
                      抛出 MQException，
                             java.io.IOException
        使用消息作为原始消息将报告消息放入队列
        参数：
        message -原始消息
        putMessageOptions -用于 MQPUT
        抛出：
        MQException -如果 MQ 调用失败
        java.io.IOException -如果存在 IO 错误

      • 关闭

        public void close()
           抛出 MQException
        关闭对象。 关闭此对象后，不允许对此对象执行任何进一步的操作。 可以通过设置 closeOptions来改变 close 方法的行为。
        覆盖：
        close的实例MQManagedObject
        抛出：
        MQException -如果 IBM MQ 调用失败。

      • getCurrent深度

        public int getCurrentDepth ()
                    抛出 MQException
        获取当前在队列中的消息数。 在 put 调用期间以及在回退 get 调用期间，此值递增。 在非浏览获取期间以及在回退 put 调用期间，将对其进行递减。
        返回：
        消息数目。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getMaximum深度

        公用整数 getMaximumDepth ()
                    抛出 MQException
        获取可同时存在于队列中的最大消息数。 尝试将消息放入已包含此大量消息的队列失败，原因码为 MQConstants.MQRC_Q_FULL。
        返回：
        最大消息数。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getMaximumMessageLength

        public int getMaximumMessageLength()
                            抛出 MQException
        获取此队列上消息的应用程序数据的最大长度。 尝试放置大于此值的消息失败，原因码为 MQConstants.MQRC_MSG_TOO_BIG_FOR_Q。
        返回：
        最大长度。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getOpenInputCount

        public int getOpenInputCount()
                      抛出 MQException
        获取用于从队列中除去消息的当前有效句柄数。
        返回：
        本地队列管理器已知的有效句柄总数，而不仅仅是那些由 IBM MQ Client for Java (使用 accessQueue()) 创建的句柄。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getOpenOutputCount

        public int getOpenOutputCount()
                       抛出 MQException
        获取用于将消息添加到队列的当前有效句柄数。
        返回：
        本地队列管理器已知的有效句柄总数，而不仅仅是那些由 IBM MQ Client for Java (使用 accessQueue()) 创建的句柄。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getTrigger控件

        public int getTrigger控制 ()
                      抛出 MQException
        指示是否将触发器消息写入启动队列。 这将启动应用程序来为队列提供服务。
        返回：
        可能的值为：
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • setTrigger控件

        public void setTriggerControl (int 触发器)
                       抛出 MQException
        控制是否将触发器消息写入启动队列。 这将启动应用程序来为队列提供服务。
        参数：
        trigger -允许的值为:
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getTrigger数据

        public java.lang.String getTriggerData ()
                                抛出 MQException
        获取写入启动队列的触发器消息的数据。 当消息到达此消息时，会将触发器消息写入启动队列。
        返回：
        数据的自由格式。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • setTrigger数据

        public void setTrigger数据 (java.lang.String 数据)
                    抛出 MQException
        设置写入启动队列的触发器消息的数据。 当消息到达此消息时，会将触发器消息写入启动队列。
        参数：
        data -以自由格式设置数据。 字符串的最大允许长度由 CMQC.MQ_TRIGGER_DATA_LENGTH给出。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getTrigger深度

        public int getTrigger深度 ()
                    抛出 MQException
        获取必须在队列上才能生成触发器消息的消息数。 当触发器类型为 CMQC.MQTT_DEPTH时适用。
        返回：
        消息数目。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • setTrigger深度

        public void setTriggerDepth (int depth)
                     抛出 MQException
        设置必须在队列上才能生成触发器消息的消息数。 当触发器类型为 CMQC.MQTT_DEPTH时适用。
        参数：
        depth -消息数。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • getTriggerMessagePriority

        public int getTriggerMessagePriority()
                              抛出 MQException
        获取消息优先级，低于此优先级的消息不会导致触发消息。 即，队列管理器在决定是否生成触发器时忽略这些消息。
        返回：
        消息优先级。 0 表示所有消息都有助于生成触发器消息。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。

      • setTriggerMessagePriority

        public void setTriggerMessagePriority(int priority)
                               抛出 MQException
        设置消息优先级，低于此优先级的消息不会导致触发消息。 即，队列管理器在决定是否生成触发器时忽略这些消息。
        参数：
        priority -消息优先级。 0 表示所有消息都有助于生成触发器消息。
        抛出：
        MQException -如果在关闭队列后调用此方法，以指示该队列不再可访问。
跳过导航链接
© Copyright IBM Corp. 2008 ， 2016. All Rights Reserved.