Блог

У меня есть код, который считывается из диспетчера очередей IBM MQ, но я хочу, чтобы его считывали из IBM MQ, не удаляя сообщение из очереди, только после того, как я отправлю подтверждение в IBM MQ, я хочу удалить сообщение

это мой код 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);
        }
    }
}
 

IBM MQ предоставляет транзакционный доступ к сообщениям, поэтому вам нужно создать транзакционный сеанс, а затем вы можете зафиксировать или откатить сообщения, полученные или отправленные по мере необходимости.

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