Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-3705

LVQ + non-destructive not deliverying message to existing consumer

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • AMQ 7.8.0.CR4
    • AMQ 7.7.0.GA
    • broker-core
    • None
    • Previously, if a client acknowledged a message on a non-destructive last value queue, and that message was subsequently replaced by another last value, the broker did not deliver the message to the client. This issue is resolved.
    • Documented as Resolved Issue
    • Verified in a release
    • Hide

      Add this to org.apache.activemq.artemis.tests.integration.jms.client.LVQTest

      @Test
public void testLVQandNonDestructive() throws Exception {
   ActiveMQConnectionFactory fact = (ActiveMQConnectionFactory) getCF();
   fact.setConsumerWindowSize(0);      

   try (Connection connection = fact.createConnection();
        Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE)) {         

      // swapping these two lines makes the test either succeed for fail
      // Queue queue = session.createQueue("random?last-value=true");
      Queue queue = session.createQueue("random?last-value=true&non-destructive=true");

      MessageProducer producer = session.createProducer(queue);
      MessageConsumer consumer = session.createConsumer(queue);

      connection.start();

      TextMessage message = session.createTextMessage();
      message.setText("Message 1");
      message.setStringProperty(Message.HDR_LAST_VALUE_NAME.toString(), "A");
      producer.send(message);

      TextMessage tm = (TextMessage) consumer.receive(2000);
      assertNotNull(tm);
      tm.acknowledge();
      assertEquals("Message 1", tm.getText());

      message = session.createTextMessage();
      message.setText("Message 2");
      message.setStringProperty(Message.HDR_LAST_VALUE_NAME.toString(), "A");
      producer.send(message);

      tm = (TextMessage) consumer.receive(2000);
      assertNotNull(tm);
      assertEquals("Message 2", tm.getText());
   }
}
      Show
      Add this to org.apache.activemq.artemis.tests.integration.jms.client.LVQTest @Test public void testLVQandNonDestructive() throws Exception { ActiveMQConnectionFactory fact = (ActiveMQConnectionFactory) getCF(); fact.setConsumerWindowSize(0); try (Connection connection = fact.createConnection(); Session session = connection.createSession( false , Session.CLIENT_ACKNOWLEDGE)) { // swapping these two lines makes the test either succeed for fail // Queue queue = session.createQueue( "random?last-value= true " ); Queue queue = session.createQueue( "random?last-value= true &non-destructive= true " ); MessageProducer producer = session.createProducer(queue); MessageConsumer consumer = session.createConsumer(queue); connection.start(); TextMessage message = session.createTextMessage(); message.setText( "Message 1" ); message.setStringProperty(Message.HDR_LAST_VALUE_NAME.toString(), "A" ); producer.send(message); TextMessage tm = (TextMessage) consumer.receive(2000); assertNotNull(tm); tm.acknowledge(); assertEquals( "Message 1" , tm.getText()); message = session.createTextMessage(); message.setText( "Message 2" ); message.setStringProperty(Message.HDR_LAST_VALUE_NAME.toString(), "A" ); producer.send(message); tm = (TextMessage) consumer.receive(2000); assertNotNull(tm); assertEquals( "Message 2" , tm.getText()); } }

    Description

      When a client acknowledges a message on a non-destructive LVQ and that message is subsequently replaced by another "last value" the broker does not deliver this message to the client.

      Attachments

        Issue Links

          is cloned by

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-3859 [LTS] LVQ + non-destructive not deliverying message to existing consumer

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed
          is duplicated by

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-4356 LVQ + non-destructive not delivering message to existing consumer

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed

          Activity

            People

              rhn-support-jbertram Justin Bertram
              rhn-support-toross Tom Ross
              Oleg Sushchenko Oleg Sushchenko
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: