[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[ https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=452719=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-452719 ] ASF GitHub Bot logged work on ARTEMIS-2819: --- Author: ASF GitHub Bot Created on: 30/Jun/20 00:44 Start Date: 30/Jun/20 00:44 Worklog Time Spent: 10m Work Description: asfgit closed pull request #3208: URL: https://github.com/apache/activemq-artemis/pull/3208 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 452719) Time Spent: 1.5h (was: 1h 20m) > Removal of address setting (exact match) ineffective > > > Key: ARTEMIS-2819 > URL: https://issues.apache.org/jira/browse/ARTEMIS-2819 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.13.0 >Reporter: Keith Wall >Priority: Major > Time Spent: 1.5h > Remaining Estimate: 0h > > If, dynamically through management, I add a settings for an address (exact > match) then later remove those settings, on re-reading the settings record > for the same address, I expect to see the settings from higher in the > hierarchy (or the root). This does not occur. It behaves as if the removal > did not take case. > I wrote a ActiveMQServerControlTest that demonstrates the problem. Looking at > the code, it appears the HierarchicalObjectRepository does not remove its > copy from the cache in the exact match case. Candidate PR raised. > [https://github.com/apache/activemq-artemis/pull/3199] > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[ https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=452720=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-452720 ] ASF GitHub Bot logged work on ARTEMIS-2819: --- Author: ASF GitHub Bot Created on: 30/Jun/20 00:44 Start Date: 30/Jun/20 00:44 Worklog Time Spent: 10m Work Description: asfgit merged pull request #3208: URL: https://github.com/apache/activemq-artemis/pull/3208 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 452720) Time Spent: 1h 40m (was: 1.5h) > Removal of address setting (exact match) ineffective > > > Key: ARTEMIS-2819 > URL: https://issues.apache.org/jira/browse/ARTEMIS-2819 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.13.0 >Reporter: Keith Wall >Priority: Major > Time Spent: 1h 40m > Remaining Estimate: 0h > > If, dynamically through management, I add a settings for an address (exact > match) then later remove those settings, on re-reading the settings record > for the same address, I expect to see the settings from higher in the > hierarchy (or the root). This does not occur. It behaves as if the removal > did not take case. > I wrote a ActiveMQServerControlTest that demonstrates the problem. Looking at > the code, it appears the HierarchicalObjectRepository does not remove its > copy from the cache in the exact match case. Candidate PR raised. > [https://github.com/apache/activemq-artemis/pull/3199] > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[ https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=452601=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-452601 ] ASF GitHub Bot logged work on ARTEMIS-2819: --- Author: ASF GitHub Bot Created on: 29/Jun/20 20:12 Start Date: 29/Jun/20 20:12 Worklog Time Spent: 10m Work Description: clebertsuconic opened a new pull request #3208: URL: https://github.com/apache/activemq-artemis/pull/3208 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 452601) Time Spent: 1h 20m (was: 1h 10m) > Removal of address setting (exact match) ineffective > > > Key: ARTEMIS-2819 > URL: https://issues.apache.org/jira/browse/ARTEMIS-2819 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.13.0 >Reporter: Keith Wall >Priority: Major > Time Spent: 1h 20m > Remaining Estimate: 0h > > If, dynamically through management, I add a settings for an address (exact > match) then later remove those settings, on re-reading the settings record > for the same address, I expect to see the settings from higher in the > hierarchy (or the root). This does not occur. It behaves as if the removal > did not take case. > I wrote a ActiveMQServerControlTest that demonstrates the problem. Looking at > the code, it appears the HierarchicalObjectRepository does not remove its > copy from the cache in the exact match case. Candidate PR raised. > [https://github.com/apache/activemq-artemis/pull/3199] > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[ https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=450556=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-450556 ] ASF GitHub Bot logged work on ARTEMIS-2819: --- Author: ASF GitHub Bot Created on: 24/Jun/20 17:55 Start Date: 24/Jun/20 17:55 Worklog Time Spent: 10m Work Description: asfgit closed pull request #3199: URL: https://github.com/apache/activemq-artemis/pull/3199 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 450556) Time Spent: 1h 10m (was: 1h) > Removal of address setting (exact match) ineffective > > > Key: ARTEMIS-2819 > URL: https://issues.apache.org/jira/browse/ARTEMIS-2819 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.13.0 >Reporter: Keith Wall >Priority: Major > Time Spent: 1h 10m > Remaining Estimate: 0h > > If, dynamically through management, I add a settings for an address (exact > match) then later remove those settings, on re-reading the settings record > for the same address, I expect to see the settings from higher in the > hierarchy (or the root). This does not occur. It behaves as if the removal > did not take case. > I wrote a ActiveMQServerControlTest that demonstrates the problem. Looking at > the code, it appears the HierarchicalObjectRepository does not remove its > copy from the cache in the exact match case. Candidate PR raised. > [https://github.com/apache/activemq-artemis/pull/3199] > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[
https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=449964=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-449964
]
ASF GitHub Bot logged work on ARTEMIS-2819:
---
Author: ASF GitHub Bot
Created on: 23/Jun/20 18:33
Start Date: 23/Jun/20 18:33
Worklog Time Spent: 10m
Work Description: k-wall commented on a change in pull request #3199:
URL: https://github.com/apache/activemq-artemis/pull/3199#discussion_r26546
##
File path:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
##
@@ -1309,6 +1309,265 @@ public void testAddressSettings() throws Exception {
}
+ @Test
+ public void testRemoveAddressSettingsEffective() throws Exception {
+ ActiveMQServerControl serverControl = createManagementControl();
+ String addr = "test";
+ String root = "#";
+
+ String DLA = "someDLA";
+ String expiryAddress = "someExpiry";
+ long expiryDelay = RandomUtil.randomPositiveLong();
+ long minExpiryDelay = 1;
+ long maxExpiryDelay = 2;
+ boolean lastValueQueue = true;
+ int deliveryAttempts = 1;
+ long maxSizeBytes = 20;
+ int pageSizeBytes = 10;
+ int pageMaxCacheSize = 7;
+ long redeliveryDelay = 4;
+ double redeliveryMultiplier = 1;
+ long maxRedeliveryDelay = 1000;
+ long redistributionDelay = 5;
+ boolean sendToDLAOnNoRoute = true;
+ String addressFullMessagePolicy = "PAGE";
+ long slowConsumerThreshold = 5;
+ long slowConsumerCheckPeriod = 10;
+ String slowConsumerPolicy =
SlowConsumerPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ boolean autoCreateJmsQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsQueues = RandomUtil.randomBoolean();
+ boolean autoCreateJmsTopics = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsTopics = RandomUtil.randomBoolean();
+ boolean autoCreateQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteQueues = RandomUtil.randomBoolean();
+ boolean autoCreateAddresses = RandomUtil.randomBoolean();
+ boolean autoDeleteAddresses = RandomUtil.randomBoolean();
+ String configDeleteQueues =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ String configDeleteAddresses =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ long maxSizeBytesRejectThreshold = RandomUtil.randomPositiveLong();
+ String defaultLastValueKey = RandomUtil.randomString();
+ boolean defaultNonDestructive = RandomUtil.randomBoolean();
+ boolean defaultExclusiveQueue = RandomUtil.randomBoolean();
+ boolean defaultGroupRebalance = RandomUtil.randomBoolean();
+ int defaultGroupBuckets = RandomUtil.randomPositiveInt();
+ String defaultGroupFirstKey = RandomUtil.randomString();
+ int defaultMaxConsumers = RandomUtil.randomPositiveInt();
+ boolean defaultPurgeOnNoConsumers = RandomUtil.randomBoolean();
+ int defaultConsumersBeforeDispatch = RandomUtil.randomPositiveInt();
+ long defaultDelayBeforeDispatch = RandomUtil.randomPositiveLong();
+ String defaultQueueRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ String defaultAddressRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ int defaultConsumerWindowSize = RandomUtil.randomPositiveInt();
+ long defaultRingSize = RandomUtil.randomPositiveLong();
+ boolean autoDeleteCreatedQueues = RandomUtil.randomBoolean();
+ long autoDeleteQueuesDelay = RandomUtil.randomPositiveLong();
+ long autoDeleteQueuesMessageCount = RandomUtil.randomPositiveLong();
+ long autoDeleteAddressesDelay = RandomUtil.randomPositiveLong();
+ double redeliveryCollisionAvoidanceFactor = RandomUtil.randomDouble();
+ long retroactiveMessageCount = RandomUtil.randomPositiveLong();
+ boolean autoCreateDeadLetterResources = RandomUtil.randomBoolean();
+ String deadLetterQueuePrefix = RandomUtil.randomString();
+ String deadLetterQueueSuffix = RandomUtil.randomString();
+ boolean autoCreateExpiryResources = RandomUtil.randomBoolean();
+ String expiryQueuePrefix = RandomUtil.randomString();
+ String expiryQueueSuffix = RandomUtil.randomString();
+ boolean enableMetrics = RandomUtil.randomBoolean();
+
+ serverControl.addAddressSettings(root,
+ DLA,
+ expiryAddress,
+ expiryDelay,
+ lastValueQueue,
+ deliveryAttempts,
+ maxSizeBytes,
+ pageSizeBytes,
+ pageMaxCacheSize,
+ redeliveryDelay,
+ redeliveryMultiplier,
+ maxRedeliveryDelay,
+ redistributionDelay,
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[
https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=449953=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-449953
]
ASF GitHub Bot logged work on ARTEMIS-2819:
---
Author: ASF GitHub Bot
Created on: 23/Jun/20 18:14
Start Date: 23/Jun/20 18:14
Worklog Time Spent: 10m
Work Description: clebertsuconic commented on a change in pull request
#3199:
URL: https://github.com/apache/activemq-artemis/pull/3199#discussion_r16390
##
File path:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
##
@@ -1309,6 +1309,265 @@ public void testAddressSettings() throws Exception {
}
+ @Test
+ public void testRemoveAddressSettingsEffective() throws Exception {
+ ActiveMQServerControl serverControl = createManagementControl();
+ String addr = "test";
+ String root = "#";
+
+ String DLA = "someDLA";
+ String expiryAddress = "someExpiry";
+ long expiryDelay = RandomUtil.randomPositiveLong();
+ long minExpiryDelay = 1;
+ long maxExpiryDelay = 2;
+ boolean lastValueQueue = true;
+ int deliveryAttempts = 1;
+ long maxSizeBytes = 20;
+ int pageSizeBytes = 10;
+ int pageMaxCacheSize = 7;
+ long redeliveryDelay = 4;
+ double redeliveryMultiplier = 1;
+ long maxRedeliveryDelay = 1000;
+ long redistributionDelay = 5;
+ boolean sendToDLAOnNoRoute = true;
+ String addressFullMessagePolicy = "PAGE";
+ long slowConsumerThreshold = 5;
+ long slowConsumerCheckPeriod = 10;
+ String slowConsumerPolicy =
SlowConsumerPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ boolean autoCreateJmsQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsQueues = RandomUtil.randomBoolean();
+ boolean autoCreateJmsTopics = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsTopics = RandomUtil.randomBoolean();
+ boolean autoCreateQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteQueues = RandomUtil.randomBoolean();
+ boolean autoCreateAddresses = RandomUtil.randomBoolean();
+ boolean autoDeleteAddresses = RandomUtil.randomBoolean();
+ String configDeleteQueues =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ String configDeleteAddresses =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ long maxSizeBytesRejectThreshold = RandomUtil.randomPositiveLong();
+ String defaultLastValueKey = RandomUtil.randomString();
+ boolean defaultNonDestructive = RandomUtil.randomBoolean();
+ boolean defaultExclusiveQueue = RandomUtil.randomBoolean();
+ boolean defaultGroupRebalance = RandomUtil.randomBoolean();
+ int defaultGroupBuckets = RandomUtil.randomPositiveInt();
+ String defaultGroupFirstKey = RandomUtil.randomString();
+ int defaultMaxConsumers = RandomUtil.randomPositiveInt();
+ boolean defaultPurgeOnNoConsumers = RandomUtil.randomBoolean();
+ int defaultConsumersBeforeDispatch = RandomUtil.randomPositiveInt();
+ long defaultDelayBeforeDispatch = RandomUtil.randomPositiveLong();
+ String defaultQueueRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ String defaultAddressRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ int defaultConsumerWindowSize = RandomUtil.randomPositiveInt();
+ long defaultRingSize = RandomUtil.randomPositiveLong();
+ boolean autoDeleteCreatedQueues = RandomUtil.randomBoolean();
+ long autoDeleteQueuesDelay = RandomUtil.randomPositiveLong();
+ long autoDeleteQueuesMessageCount = RandomUtil.randomPositiveLong();
+ long autoDeleteAddressesDelay = RandomUtil.randomPositiveLong();
+ double redeliveryCollisionAvoidanceFactor = RandomUtil.randomDouble();
+ long retroactiveMessageCount = RandomUtil.randomPositiveLong();
+ boolean autoCreateDeadLetterResources = RandomUtil.randomBoolean();
+ String deadLetterQueuePrefix = RandomUtil.randomString();
+ String deadLetterQueueSuffix = RandomUtil.randomString();
+ boolean autoCreateExpiryResources = RandomUtil.randomBoolean();
+ String expiryQueuePrefix = RandomUtil.randomString();
+ String expiryQueueSuffix = RandomUtil.randomString();
+ boolean enableMetrics = RandomUtil.randomBoolean();
+
+ serverControl.addAddressSettings(root,
+ DLA,
+ expiryAddress,
+ expiryDelay,
+ lastValueQueue,
+ deliveryAttempts,
+ maxSizeBytes,
+ pageSizeBytes,
+ pageMaxCacheSize,
+ redeliveryDelay,
+ redeliveryMultiplier,
+ maxRedeliveryDelay,
+
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[
https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=449948=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-449948
]
ASF GitHub Bot logged work on ARTEMIS-2819:
---
Author: ASF GitHub Bot
Created on: 23/Jun/20 18:09
Start Date: 23/Jun/20 18:09
Worklog Time Spent: 10m
Work Description: k-wall commented on a change in pull request #3199:
URL: https://github.com/apache/activemq-artemis/pull/3199#discussion_r13620
##
File path:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
##
@@ -1309,6 +1309,265 @@ public void testAddressSettings() throws Exception {
}
+ @Test
+ public void testRemoveAddressSettingsEffective() throws Exception {
+ ActiveMQServerControl serverControl = createManagementControl();
+ String addr = "test";
+ String root = "#";
+
+ String DLA = "someDLA";
+ String expiryAddress = "someExpiry";
+ long expiryDelay = RandomUtil.randomPositiveLong();
+ long minExpiryDelay = 1;
+ long maxExpiryDelay = 2;
+ boolean lastValueQueue = true;
+ int deliveryAttempts = 1;
+ long maxSizeBytes = 20;
+ int pageSizeBytes = 10;
+ int pageMaxCacheSize = 7;
+ long redeliveryDelay = 4;
+ double redeliveryMultiplier = 1;
+ long maxRedeliveryDelay = 1000;
+ long redistributionDelay = 5;
+ boolean sendToDLAOnNoRoute = true;
+ String addressFullMessagePolicy = "PAGE";
+ long slowConsumerThreshold = 5;
+ long slowConsumerCheckPeriod = 10;
+ String slowConsumerPolicy =
SlowConsumerPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ boolean autoCreateJmsQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsQueues = RandomUtil.randomBoolean();
+ boolean autoCreateJmsTopics = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsTopics = RandomUtil.randomBoolean();
+ boolean autoCreateQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteQueues = RandomUtil.randomBoolean();
+ boolean autoCreateAddresses = RandomUtil.randomBoolean();
+ boolean autoDeleteAddresses = RandomUtil.randomBoolean();
+ String configDeleteQueues =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ String configDeleteAddresses =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ long maxSizeBytesRejectThreshold = RandomUtil.randomPositiveLong();
+ String defaultLastValueKey = RandomUtil.randomString();
+ boolean defaultNonDestructive = RandomUtil.randomBoolean();
+ boolean defaultExclusiveQueue = RandomUtil.randomBoolean();
+ boolean defaultGroupRebalance = RandomUtil.randomBoolean();
+ int defaultGroupBuckets = RandomUtil.randomPositiveInt();
+ String defaultGroupFirstKey = RandomUtil.randomString();
+ int defaultMaxConsumers = RandomUtil.randomPositiveInt();
+ boolean defaultPurgeOnNoConsumers = RandomUtil.randomBoolean();
+ int defaultConsumersBeforeDispatch = RandomUtil.randomPositiveInt();
+ long defaultDelayBeforeDispatch = RandomUtil.randomPositiveLong();
+ String defaultQueueRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ String defaultAddressRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ int defaultConsumerWindowSize = RandomUtil.randomPositiveInt();
+ long defaultRingSize = RandomUtil.randomPositiveLong();
+ boolean autoDeleteCreatedQueues = RandomUtil.randomBoolean();
+ long autoDeleteQueuesDelay = RandomUtil.randomPositiveLong();
+ long autoDeleteQueuesMessageCount = RandomUtil.randomPositiveLong();
+ long autoDeleteAddressesDelay = RandomUtil.randomPositiveLong();
+ double redeliveryCollisionAvoidanceFactor = RandomUtil.randomDouble();
+ long retroactiveMessageCount = RandomUtil.randomPositiveLong();
+ boolean autoCreateDeadLetterResources = RandomUtil.randomBoolean();
+ String deadLetterQueuePrefix = RandomUtil.randomString();
+ String deadLetterQueueSuffix = RandomUtil.randomString();
+ boolean autoCreateExpiryResources = RandomUtil.randomBoolean();
+ String expiryQueuePrefix = RandomUtil.randomString();
+ String expiryQueueSuffix = RandomUtil.randomString();
+ boolean enableMetrics = RandomUtil.randomBoolean();
+
+ serverControl.addAddressSettings(root,
+ DLA,
+ expiryAddress,
+ expiryDelay,
+ lastValueQueue,
+ deliveryAttempts,
+ maxSizeBytes,
+ pageSizeBytes,
+ pageMaxCacheSize,
+ redeliveryDelay,
+ redeliveryMultiplier,
+ maxRedeliveryDelay,
+ redistributionDelay,
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[
https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=449949=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-449949
]
ASF GitHub Bot logged work on ARTEMIS-2819:
---
Author: ASF GitHub Bot
Created on: 23/Jun/20 18:09
Start Date: 23/Jun/20 18:09
Worklog Time Spent: 10m
Work Description: k-wall commented on a change in pull request #3199:
URL: https://github.com/apache/activemq-artemis/pull/3199#discussion_r13620
##
File path:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
##
@@ -1309,6 +1309,265 @@ public void testAddressSettings() throws Exception {
}
+ @Test
+ public void testRemoveAddressSettingsEffective() throws Exception {
+ ActiveMQServerControl serverControl = createManagementControl();
+ String addr = "test";
+ String root = "#";
+
+ String DLA = "someDLA";
+ String expiryAddress = "someExpiry";
+ long expiryDelay = RandomUtil.randomPositiveLong();
+ long minExpiryDelay = 1;
+ long maxExpiryDelay = 2;
+ boolean lastValueQueue = true;
+ int deliveryAttempts = 1;
+ long maxSizeBytes = 20;
+ int pageSizeBytes = 10;
+ int pageMaxCacheSize = 7;
+ long redeliveryDelay = 4;
+ double redeliveryMultiplier = 1;
+ long maxRedeliveryDelay = 1000;
+ long redistributionDelay = 5;
+ boolean sendToDLAOnNoRoute = true;
+ String addressFullMessagePolicy = "PAGE";
+ long slowConsumerThreshold = 5;
+ long slowConsumerCheckPeriod = 10;
+ String slowConsumerPolicy =
SlowConsumerPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ boolean autoCreateJmsQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsQueues = RandomUtil.randomBoolean();
+ boolean autoCreateJmsTopics = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsTopics = RandomUtil.randomBoolean();
+ boolean autoCreateQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteQueues = RandomUtil.randomBoolean();
+ boolean autoCreateAddresses = RandomUtil.randomBoolean();
+ boolean autoDeleteAddresses = RandomUtil.randomBoolean();
+ String configDeleteQueues =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ String configDeleteAddresses =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ long maxSizeBytesRejectThreshold = RandomUtil.randomPositiveLong();
+ String defaultLastValueKey = RandomUtil.randomString();
+ boolean defaultNonDestructive = RandomUtil.randomBoolean();
+ boolean defaultExclusiveQueue = RandomUtil.randomBoolean();
+ boolean defaultGroupRebalance = RandomUtil.randomBoolean();
+ int defaultGroupBuckets = RandomUtil.randomPositiveInt();
+ String defaultGroupFirstKey = RandomUtil.randomString();
+ int defaultMaxConsumers = RandomUtil.randomPositiveInt();
+ boolean defaultPurgeOnNoConsumers = RandomUtil.randomBoolean();
+ int defaultConsumersBeforeDispatch = RandomUtil.randomPositiveInt();
+ long defaultDelayBeforeDispatch = RandomUtil.randomPositiveLong();
+ String defaultQueueRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ String defaultAddressRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ int defaultConsumerWindowSize = RandomUtil.randomPositiveInt();
+ long defaultRingSize = RandomUtil.randomPositiveLong();
+ boolean autoDeleteCreatedQueues = RandomUtil.randomBoolean();
+ long autoDeleteQueuesDelay = RandomUtil.randomPositiveLong();
+ long autoDeleteQueuesMessageCount = RandomUtil.randomPositiveLong();
+ long autoDeleteAddressesDelay = RandomUtil.randomPositiveLong();
+ double redeliveryCollisionAvoidanceFactor = RandomUtil.randomDouble();
+ long retroactiveMessageCount = RandomUtil.randomPositiveLong();
+ boolean autoCreateDeadLetterResources = RandomUtil.randomBoolean();
+ String deadLetterQueuePrefix = RandomUtil.randomString();
+ String deadLetterQueueSuffix = RandomUtil.randomString();
+ boolean autoCreateExpiryResources = RandomUtil.randomBoolean();
+ String expiryQueuePrefix = RandomUtil.randomString();
+ String expiryQueueSuffix = RandomUtil.randomString();
+ boolean enableMetrics = RandomUtil.randomBoolean();
+
+ serverControl.addAddressSettings(root,
+ DLA,
+ expiryAddress,
+ expiryDelay,
+ lastValueQueue,
+ deliveryAttempts,
+ maxSizeBytes,
+ pageSizeBytes,
+ pageMaxCacheSize,
+ redeliveryDelay,
+ redeliveryMultiplier,
+ maxRedeliveryDelay,
+ redistributionDelay,
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[
https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=449942=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-449942
]
ASF GitHub Bot logged work on ARTEMIS-2819:
---
Author: ASF GitHub Bot
Created on: 23/Jun/20 17:53
Start Date: 23/Jun/20 17:53
Worklog Time Spent: 10m
Work Description: clebertsuconic commented on a change in pull request
#3199:
URL: https://github.com/apache/activemq-artemis/pull/3199#discussion_r04630
##
File path:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
##
@@ -1309,6 +1309,265 @@ public void testAddressSettings() throws Exception {
}
+ @Test
+ public void testRemoveAddressSettingsEffective() throws Exception {
+ ActiveMQServerControl serverControl = createManagementControl();
+ String addr = "test";
+ String root = "#";
+
+ String DLA = "someDLA";
+ String expiryAddress = "someExpiry";
+ long expiryDelay = RandomUtil.randomPositiveLong();
+ long minExpiryDelay = 1;
+ long maxExpiryDelay = 2;
+ boolean lastValueQueue = true;
+ int deliveryAttempts = 1;
+ long maxSizeBytes = 20;
+ int pageSizeBytes = 10;
+ int pageMaxCacheSize = 7;
+ long redeliveryDelay = 4;
+ double redeliveryMultiplier = 1;
+ long maxRedeliveryDelay = 1000;
+ long redistributionDelay = 5;
+ boolean sendToDLAOnNoRoute = true;
+ String addressFullMessagePolicy = "PAGE";
+ long slowConsumerThreshold = 5;
+ long slowConsumerCheckPeriod = 10;
+ String slowConsumerPolicy =
SlowConsumerPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ boolean autoCreateJmsQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsQueues = RandomUtil.randomBoolean();
+ boolean autoCreateJmsTopics = RandomUtil.randomBoolean();
+ boolean autoDeleteJmsTopics = RandomUtil.randomBoolean();
+ boolean autoCreateQueues = RandomUtil.randomBoolean();
+ boolean autoDeleteQueues = RandomUtil.randomBoolean();
+ boolean autoCreateAddresses = RandomUtil.randomBoolean();
+ boolean autoDeleteAddresses = RandomUtil.randomBoolean();
+ String configDeleteQueues =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ String configDeleteAddresses =
DeletionPolicy.getType(RandomUtil.randomPositiveInt() % 2).toString();
+ long maxSizeBytesRejectThreshold = RandomUtil.randomPositiveLong();
+ String defaultLastValueKey = RandomUtil.randomString();
+ boolean defaultNonDestructive = RandomUtil.randomBoolean();
+ boolean defaultExclusiveQueue = RandomUtil.randomBoolean();
+ boolean defaultGroupRebalance = RandomUtil.randomBoolean();
+ int defaultGroupBuckets = RandomUtil.randomPositiveInt();
+ String defaultGroupFirstKey = RandomUtil.randomString();
+ int defaultMaxConsumers = RandomUtil.randomPositiveInt();
+ boolean defaultPurgeOnNoConsumers = RandomUtil.randomBoolean();
+ int defaultConsumersBeforeDispatch = RandomUtil.randomPositiveInt();
+ long defaultDelayBeforeDispatch = RandomUtil.randomPositiveLong();
+ String defaultQueueRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ String defaultAddressRoutingType = RoutingType.getType((byte)
(RandomUtil.randomPositiveInt() % 2)).toString();
+ int defaultConsumerWindowSize = RandomUtil.randomPositiveInt();
+ long defaultRingSize = RandomUtil.randomPositiveLong();
+ boolean autoDeleteCreatedQueues = RandomUtil.randomBoolean();
+ long autoDeleteQueuesDelay = RandomUtil.randomPositiveLong();
+ long autoDeleteQueuesMessageCount = RandomUtil.randomPositiveLong();
+ long autoDeleteAddressesDelay = RandomUtil.randomPositiveLong();
+ double redeliveryCollisionAvoidanceFactor = RandomUtil.randomDouble();
+ long retroactiveMessageCount = RandomUtil.randomPositiveLong();
+ boolean autoCreateDeadLetterResources = RandomUtil.randomBoolean();
+ String deadLetterQueuePrefix = RandomUtil.randomString();
+ String deadLetterQueueSuffix = RandomUtil.randomString();
+ boolean autoCreateExpiryResources = RandomUtil.randomBoolean();
+ String expiryQueuePrefix = RandomUtil.randomString();
+ String expiryQueueSuffix = RandomUtil.randomString();
+ boolean enableMetrics = RandomUtil.randomBoolean();
+
+ serverControl.addAddressSettings(root,
+ DLA,
+ expiryAddress,
+ expiryDelay,
+ lastValueQueue,
+ deliveryAttempts,
+ maxSizeBytes,
+ pageSizeBytes,
+ pageMaxCacheSize,
+ redeliveryDelay,
+ redeliveryMultiplier,
+ maxRedeliveryDelay,
+
[jira] [Work logged] (ARTEMIS-2819) Removal of address setting (exact match) ineffective
[ https://issues.apache.org/jira/browse/ARTEMIS-2819?focusedWorklogId=449914=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-449914 ] ASF GitHub Bot logged work on ARTEMIS-2819: --- Author: ASF GitHub Bot Created on: 23/Jun/20 17:06 Start Date: 23/Jun/20 17:06 Worklog Time Spent: 10m Work Description: k-wall opened a new pull request #3199: URL: https://github.com/apache/activemq-artemis/pull/3199 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 449914) Remaining Estimate: 0h Time Spent: 10m > Removal of address setting (exact match) ineffective > > > Key: ARTEMIS-2819 > URL: https://issues.apache.org/jira/browse/ARTEMIS-2819 > Project: ActiveMQ Artemis > Issue Type: Bug >Reporter: Keith Wall >Priority: Major > Time Spent: 10m > Remaining Estimate: 0h > > If, dynamically through management, I add a settings for an address (exact > match) then later remove those settings, on re-reading the settings record > for the address, I expect to see the settings from higher in the hierarchy > (or the root). This does not occur. It behaves as if the removal did not > take case. > I wrote a ActiveMQServerControlTest that demonstrates the problem. Looking at > the code, it appears the HierarchicalObjectRepository does not remove its > copy from the cache. Candidate PR raised. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
