This content has been marked as final. Show 3 replies
This came into my attention as I was writing a test.
I" m sending a message as:
Expiry Address is properly configured:
AddressSettings addressSettings = new AddressSettings(); addressSettings.setExpiryAddress(ADDRESS_EXPIRY); server.getAddressSettingsRepository().addMatch("*", addressSettings);
But no message expiried until I added these two lines of code:
ClientConsumer consumer2 = session.createConsumer(ADDRESS); assertNull(consumer2.receive(1000));
we have an expiry reaper that runs every thirty seconds and expires messages on the server.