From 2a682e2fb2b0f4fc212e89dc13d08a61c3cc1aea Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Sat, 30 Dec 2006 07:27:06 +0000
Subject: [PATCH] Applied patch from:
 https://issues.apache.org/activemq/browse/AMQ-961

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491185 13f79535-47bb-0310-9956-ffa450edef68
---
 .../network/DemandForwardingBridgeSupport.java        | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
index 97c24b6989..7551a464d3 100644
--- a/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
@@ -176,8 +176,15 @@ public abstract class DemandForwardingBridgeSupport implements Bridge {
 						}
                 	}
                     lastConnectSucceeded.set(false);
-
-                    log.debug("Outbound transport to " + remoteBrokerName + " resumed");                                        
+                    try {
+                        startLocalBridge();
+                        remoteBridgeStarted.set(true);
+                        startedLatch.countDown();
+                        log.debug("Outbound transport to " + remoteBrokerName + " resumed");   
+                    }catch(Exception e) {
+                        log.error("Caught exception  from local start ib resume transport",e );
+                    }
+                                                         
                 }
             }
         });