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

Fix for https://issues.apache.org/activemq/browse/AMQ-910 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@812932 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2009-09-09 13:03:03 +00:00
parent f89bf4765f
commit 487f2cca03
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/main/java/org/apache/activemq/RedeliveryPolicy.java
View File

@ -37,7 +37,7 @@ public class RedeliveryPolicy implements Cloneable, Serializable {
private long initialRedeliveryDelay = 1000L; private long initialRedeliveryDelay = 1000L;
private boolean useCollisionAvoidance; private boolean useCollisionAvoidance;
private boolean useExponentialBackOff; private boolean useExponentialBackOff;
private short backOffMultiplier = 5; private double backOffMultiplier = 5.0;
public RedeliveryPolicy() { public RedeliveryPolicy() {
} }
@ -50,11 +50,11 @@ public class RedeliveryPolicy implements Cloneable, Serializable {
} }
} }
public short getBackOffMultiplier() { public double getBackOffMultiplier() {
return backOffMultiplier; return backOffMultiplier;
} }
public void setBackOffMultiplier(short backOffMultiplier) { public void setBackOffMultiplier(double backOffMultiplier) {
this.backOffMultiplier = backOffMultiplier; this.backOffMultiplier = backOffMultiplier;
} }
@ -88,7 +88,7 @@ public class RedeliveryPolicy implements Cloneable, Serializable {
if (previousDelay == 0) { if (previousDelay == 0) {
redeliveryDelay = initialRedeliveryDelay; redeliveryDelay = initialRedeliveryDelay;
} else if (useExponentialBackOff && backOffMultiplier > 1) { } else if (useExponentialBackOff && backOffMultiplier > 1) {
redeliveryDelay = previousDelay * backOffMultiplier; redeliveryDelay = (long) (previousDelay * backOffMultiplier);
} else { } else {
redeliveryDelay = previousDelay; redeliveryDelay = previousDelay;
} }