[jboss-dev-forums] [Design of Messaging on JBoss (Messaging/JBoss)] - Re: Expiry requires a consumer in order to work?

[clebert.suconic@jboss.com]

This came into my attention as I was writing a test.


I" m sending a message as:


  |          clientFile.setExpiration(System.currentTimeMillis());
  | 
  |          producer.send(clientFile);
  | 

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));
  | 

View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4244739#4244739

Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4244739