This closes #4176
This commit is contained in:
commit
aa11a82e0b
|
@ -224,6 +224,9 @@ public class LastValueQueue extends QueueImpl {
|
||||||
if (current == ref) {
|
if (current == ref) {
|
||||||
currentLastValue = true;
|
currentLastValue = true;
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
// if the ref has no last value
|
||||||
|
return true;
|
||||||
}
|
}
|
||||||
return currentLastValue;
|
return currentLastValue;
|
||||||
}
|
}
|
||||||
|
|
|
@ -140,6 +140,28 @@ public class LVQTest extends ActiveMQTestBase {
|
||||||
Assert.assertEquals(m.getBodyBuffer().readString(), "m4");
|
Assert.assertEquals(m.getBodyBuffer().readString(), "m4");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testMultipleMessagesWithoutLastValue() throws Exception {
|
||||||
|
ClientProducer producer = clientSession.createProducer(address);
|
||||||
|
ClientMessage m1 = createTextMessage(clientSession, "message1");
|
||||||
|
ClientMessage m2 = createTextMessage(clientSession, "message2");
|
||||||
|
producer.send(m1);
|
||||||
|
producer.send(m2);
|
||||||
|
|
||||||
|
Wait.assertEquals(2L, () -> server.locateQueue(qName1).getMessageCount(), 2000, 100);
|
||||||
|
|
||||||
|
ClientConsumer consumer = clientSession.createConsumer(qName1);
|
||||||
|
clientSession.start();
|
||||||
|
ClientMessage m = consumer.receive(1000);
|
||||||
|
Assert.assertNotNull(m);
|
||||||
|
m.acknowledge();
|
||||||
|
Assert.assertEquals("message1", m.getBodyBuffer().readString());
|
||||||
|
m = consumer.receive(1000);
|
||||||
|
Assert.assertNotNull(m);
|
||||||
|
m.acknowledge();
|
||||||
|
Assert.assertEquals("message2", m.getBodyBuffer().readString());
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testMultipleRollback() throws Exception {
|
public void testMultipleRollback() throws Exception {
|
||||||
AddressSettings qs = new AddressSettings();
|
AddressSettings qs = new AddressSettings();
|
||||||
|
|
Loading…
Reference in New Issue