如何使用java向ibm mq发送ack消息

dwthyt8l  于 2021-07-03  发布在  Java
关注(0)|答案(1)|浏览(425)

我有一个从ibmq队列管理器读取的代码,但是我希望在不从队列中删除消息的情况下从ibmq读取,只有在我向ibmq发送确认之后,我才希望删除消息
这是我的ibm reader代码:

public class IBMReaderStub extends AbstractReader {
    private JMSContext context = null;
    JMSConsumer consumer;
    Destination destination;

    public IBMReaderStub(String queueName) {
        this(queueName, new IBMListener());
    }

    public IBMReaderStub(String queueName, IBMListener onMessage) {
        super(ConfigurationManager.getString(HOST), ConfigurationManager.getInt(PORT, DEFAULT_IBM_PORT), queueName, new QueueWithThreadPool(), onMessage);
    }

    @Override
    protected void initializeConsumer() {
        try {
            JmsConnectionFactory jmsConnectionFactory = createJmsConnectionFactory();
            context = jmsConnectionFactory.createContext();
            destination = context.createQueue("queue:///" + getQueueName()); // Set the producer and consumer destination to be the same... not true in general
            consumer = context.createConsumer(destination);
        } catch (Exception e) {
            System.out.println(e);
        }
        listen();
    }

    @Override
    public void listen() {
        consumer.setMessageListener(getOnMessage());
    }

    private JmsConnectionFactory createJmsConnectionFactory() throws Exception {
        JmsFactoryFactory jmsFactory = JmsFactoryFactory.getInstance(WMQConstants.WMQ_PROVIDER);
        JmsConnectionFactory jmsConnectionFactory = jmsFactory.createConnectionFactory();
        jmsConnectionFactory.setStringProperty(WMQConstants.WMQ_HOST_NAME, this.getHost());
        jmsConnectionFactory.setIntProperty(WMQConstants.WMQ_PORT, getPort());
        jmsConnectionFactory.setStringProperty(WMQConstants.WMQ_CHANNEL, ConfigurationManager.getString(CHANNEL_NAME));
        jmsConnectionFactory.setStringProperty(WMQConstants.WMQ_QUEUE_MANAGER, ConfigurationManager.getString(QUEUE_MANAGER_NAME));
        jmsConnectionFactory.setStringProperty(WMQConstants.WMQ_APPLICATIONNAME, ConfigurationManager.getString(APPLICATION_NAME));
        jmsConnectionFactory.setIntProperty(WMQConstants.WMQ_CONNECTION_MODE, WMQConstants.WMQ_CM_CLIENT);
        return jmsConnectionFactory;
    }

    public static void main(String[] args) {
        try {
            IBMReaderStub reader = new IBMReaderStub("hey");
            IBMReaderStub reader2 = new IBMReaderStub("hey");
            reader.listen();
            reader2.listen();

        } catch (Exception e) {
            System.out.println(e);
        }
    }
}
0kjbasz6

0kjbasz61#

ibmq提供了对消息的事务访问,因此您需要创建一个事务会话,然后您可以根据需要提交或回滚消息get或put。
https://www.ibm.com/support/knowledgecenter/ssfksj_9.1.0/com.ibm.mq.dev.doc/q032210_.html
https://www.ibm.com/support/knowledgecenter/ssfksj_8.0.0/com.ibm.mq.dev.doc/q032220_.htm

相关问题