Attachment 687358 Details for Bug 904010 – Simple patch proposal

[patch] Simple patch proposal

bz904010.patch (text/plain), 1.78 KB, created by Pavel Moravec on 2013-01-25 09:40:34 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2013-01-25 09:40:34 UTC

Size: 1.78 KB

patch

obsolete

>diff -rup _qpid-0.18-orig/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverRoundRobinServers.java _qpid-0.18-new/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverRoundRobinServers.java
>--- _qpid-0.18-orig/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverRoundRobinServers.java	2012-01-29 14:05:07.000000000 +0100
>+++ _qpid-0.18-new/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverRoundRobinServers.java	2013-01-25 09:30:40.437386006 +0100
>@@ -114,14 +115,11 @@ public class FailoverRoundRobinServers i
> 
>     public BrokerDetails getNextBrokerDetails()
>     {
>-        boolean doDelay = false;
>-
>         if (_currentBrokerIndex == (_connectionDetails.getBrokerCount() - 1))
>         {
>             if (_currentServerRetry < _serverRetries)
>             {
>                 _logger.info("Trying " + _connectionDetails.getBrokerDetails(_currentBrokerIndex));
>-                doDelay= _currentBrokerIndex != 0;
>                 _currentServerRetry++;
>             }
>             else
>@@ -142,7 +140,6 @@ public class FailoverRoundRobinServers i
>             if (_currentServerRetry < _serverRetries)
>             {
>                 _logger.info("Trying " + _connectionDetails.getBrokerDetails(_currentBrokerIndex));
>-                doDelay= _currentBrokerIndex != 0;
> 
>                 _currentServerRetry++;
>             }
>@@ -159,7 +156,7 @@ public class FailoverRoundRobinServers i
>         BrokerDetails broker = _connectionDetails.getBrokerDetails(_currentBrokerIndex);
> 
>         String delayStr = broker.getProperty(BrokerDetails.OPTIONS_CONNECT_DELAY);
>-        if (delayStr != null && doDelay)
>+        if (delayStr != null)
>         {
>             Long delay = Long.parseLong(delayStr);
>             _logger.info("Delay between connect retries:" + delay);

Actions: View | Diff

Attachments on bug 904010: 687358 | 781352