Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #4182

This commit is contained in:
Justin Bertram 2022-08-19 22:38:42 -05:00
parent 86db53da9a f1c9e3df14
commit fb292fde35
No known key found for this signature in database
GPG Key ID: F41830B875BB8633
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.java
View File

@ -175,11 +175,11 @@ public class AddressSettings implements Mergeable<AddressSettings>, Serializable
private SimpleString expiryAddress = null; private SimpleString expiryAddress = null;
private Long expiryDelay = AddressSettings.DEFAULT_EXPIRY_DELAY; private Long expiryDelay = null;
private Long minExpiryDelay = AddressSettings.DEFAULT_MIN_EXPIRY_DELAY; private Long minExpiryDelay = null;
private Long maxExpiryDelay = AddressSettings.DEFAULT_MAX_EXPIRY_DELAY; private Long maxExpiryDelay = null;
private Boolean defaultLastValueQueue = null; private Boolean defaultLastValueQueue = null;
@ -769,7 +769,7 @@ public class AddressSettings implements Mergeable<AddressSettings>, Serializable
} }
public Long getExpiryDelay() { public Long getExpiryDelay() {
return expiryDelay; return expiryDelay != null ? expiryDelay : AddressSettings.DEFAULT_EXPIRY_DELAY;
} }
public AddressSettings setExpiryDelay(final Long expiryDelay) { public AddressSettings setExpiryDelay(final Long expiryDelay) {
@ -778,7 +778,7 @@ public class AddressSettings implements Mergeable<AddressSettings>, Serializable
} }
public Long getMinExpiryDelay() { public Long getMinExpiryDelay() {
return minExpiryDelay; return minExpiryDelay != null ? minExpiryDelay : AddressSettings.DEFAULT_MIN_EXPIRY_DELAY;
} }
public AddressSettings setMinExpiryDelay(final Long minExpiryDelay) { public AddressSettings setMinExpiryDelay(final Long minExpiryDelay) {
@ -787,7 +787,7 @@ public class AddressSettings implements Mergeable<AddressSettings>, Serializable
} }
public Long getMaxExpiryDelay() { public Long getMaxExpiryDelay() {
return maxExpiryDelay; return maxExpiryDelay != null ? maxExpiryDelay : AddressSettings.DEFAULT_MAX_EXPIRY_DELAY;
} }
public AddressSettings setMaxExpiryDelay(final Long maxExpiryDelay) { public AddressSettings setMaxExpiryDelay(final Long maxExpiryDelay) {

6
artemis-server/src/test/java/org/apache/activemq/artemis/core/settings/AddressSettingsTest.java
View File

@ -71,6 +71,9 @@ public class AddressSettingsTest extends ActiveMQTestBase {
addressSettingsToMerge.setPageSizeBytes(1004); addressSettingsToMerge.setPageSizeBytes(1004);
addressSettingsToMerge.setMaxSizeBytesRejectThreshold(10 * 1024); addressSettingsToMerge.setMaxSizeBytesRejectThreshold(10 * 1024);
addressSettingsToMerge.setConfigDeleteDiverts(DeletionPolicy.FORCE); addressSettingsToMerge.setConfigDeleteDiverts(DeletionPolicy.FORCE);
addressSettingsToMerge.setExpiryDelay(999L);
addressSettingsToMerge.setMinExpiryDelay(888L);
addressSettingsToMerge.setMaxExpiryDelay(777L);
addressSettings.merge(addressSettingsToMerge); addressSettings.merge(addressSettingsToMerge);
Assert.assertEquals(addressSettings.getDeadLetterAddress(), DLQ); Assert.assertEquals(addressSettings.getDeadLetterAddress(), DLQ);
@ -84,6 +87,9 @@ public class AddressSettingsTest extends ActiveMQTestBase {
Assert.assertEquals(AddressFullMessagePolicy.DROP, addressSettings.getAddressFullMessagePolicy()); Assert.assertEquals(AddressFullMessagePolicy.DROP, addressSettings.getAddressFullMessagePolicy());
Assert.assertEquals(addressSettings.getMaxSizeBytesRejectThreshold(), 10 * 1024); Assert.assertEquals(addressSettings.getMaxSizeBytesRejectThreshold(), 10 * 1024);
Assert.assertEquals(DeletionPolicy.FORCE, addressSettings.getConfigDeleteDiverts()); Assert.assertEquals(DeletionPolicy.FORCE, addressSettings.getConfigDeleteDiverts());
Assert.assertEquals(Long.valueOf(999), addressSettings.getExpiryDelay());
Assert.assertEquals(Long.valueOf(888), addressSettings.getMinExpiryDelay());
Assert.assertEquals(Long.valueOf(777), addressSettings.getMaxExpiryDelay());
} }
@Test @Test