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

Replace use of depricated setInactiveTimoutBeforeGC

This commit is contained in:
Alexej Timonin 2024-07-23 22:25:45 +02:00
parent 7e4faa3493
commit efe716f3b3
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3157Test.java
View File

@ -122,7 +122,7 @@ public class AMQ3157Test extends EmbeddedBrokerTestSupport {
PolicyEntry entry = new PolicyEntry(); PolicyEntry entry = new PolicyEntry();
entry.setGcInactiveDestinations(true); entry.setGcInactiveDestinations(true);
entry.setInactiveTimoutBeforeGC(5000); entry.setInactiveTimeoutBeforeGC(5000);
entry.setProducerFlowControl(true); entry.setProducerFlowControl(true);
PolicyMap map = new PolicyMap(); PolicyMap map = new PolicyMap();
map.setDefaultEntry(entry); map.setDefaultEntry(entry);

2
activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3324Test.java
View File

@ -127,7 +127,7 @@ public class AMQ3324Test {
PolicyEntry entry = new PolicyEntry(); PolicyEntry entry = new PolicyEntry();
entry.setGcInactiveDestinations(true); entry.setGcInactiveDestinations(true);
entry.setInactiveTimoutBeforeGC(2000); entry.setInactiveTimeoutBeforeGC(2000);
entry.setProducerFlowControl(true); entry.setProducerFlowControl(true);
entry.setAdvisoryForConsumed(true); entry.setAdvisoryForConsumed(true);
entry.setAdvisoryForFastProducers(true); entry.setAdvisoryForFastProducers(true);

2
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyNoAdvisoryNetworkTest.java
View File

@ -270,7 +270,7 @@ public class RequestReplyNoAdvisoryNetworkTest extends JmsMultipleBrokersTestSup
tempReplyQPolicy.setOptimizedDispatch(true); tempReplyQPolicy.setOptimizedDispatch(true);
tempReplyQPolicy.setGcInactiveDestinations(true); tempReplyQPolicy.setGcInactiveDestinations(true);
tempReplyQPolicy.setGcWithNetworkConsumers(true); tempReplyQPolicy.setGcWithNetworkConsumers(true);
tempReplyQPolicy.setInactiveTimoutBeforeGC(1000); tempReplyQPolicy.setInactiveTimeoutBeforeGC(1000);
map.put(replyQWildcard, tempReplyQPolicy); map.put(replyQWildcard, tempReplyQPolicy);
broker.setDestinationPolicy(map); broker.setDestinationPolicy(map);