Skip to content

Commit

Permalink
[AMQ-9543] Replace use of deprecated setInactiveTimoutBeforeGC in uni…
Browse files Browse the repository at this point in the history
…t tests (#1269)

* Fix typo in the deprication doc

* Replace use of depricated setInactiveTimoutBeforeGC
  • Loading branch information
AlexejTimonin authored Dec 18, 2024
1 parent 3b759d2 commit cb52807
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1040,7 +1040,7 @@ public void setGcInactiveDestinations(boolean gcInactiveDestinations) {
/**
* @return the amount of time spent inactive before GC of the destination kicks in.
*
* @deprecated use getInactiveTimeoutBeforeGC instead.
* @deprecated use {@link #getInactiveTimeoutBeforeGC} instead.
*/
@Deprecated
public long getInactiveTimoutBeforeGC() {
Expand All @@ -1053,7 +1053,7 @@ public long getInactiveTimoutBeforeGC() {
* @param inactiveTimoutBeforeGC
* time in milliseconds to configure as the inactive timeout.
*
* @deprecated use getInactiveTimeoutBeforeGC instead.
* @deprecated use {@link #setInactiveTimeoutBeforeGC} instead.
*/
@Deprecated
public void setInactiveTimoutBeforeGC(long inactiveTimoutBeforeGC) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ protected BrokerService createBroker() throws Exception {

PolicyEntry entry = new PolicyEntry();
entry.setGcInactiveDestinations(true);
entry.setInactiveTimoutBeforeGC(5000);
entry.setInactiveTimeoutBeforeGC(5000);
entry.setProducerFlowControl(true);
PolicyMap map = new PolicyMap();
map.setDefaultEntry(entry);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ protected BrokerService createBroker() throws Exception {

PolicyEntry entry = new PolicyEntry();
entry.setGcInactiveDestinations(true);
entry.setInactiveTimoutBeforeGC(2000);
entry.setInactiveTimeoutBeforeGC(2000);
entry.setProducerFlowControl(true);
entry.setAdvisoryForConsumed(true);
entry.setAdvisoryForFastProducers(true);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ private BrokerService configureBroker(String brokerName) throws Exception {
tempReplyQPolicy.setOptimizedDispatch(true);
tempReplyQPolicy.setGcInactiveDestinations(true);
tempReplyQPolicy.setGcWithNetworkConsumers(true);
tempReplyQPolicy.setInactiveTimoutBeforeGC(1000);
tempReplyQPolicy.setInactiveTimeoutBeforeGC(1000);
map.put(replyQWildcard, tempReplyQPolicy);
broker.setDestinationPolicy(map);

Expand Down

0 comments on commit cb52807

Please sign in to comment.