diff --git a/activemq-core/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java b/activemq-core/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java
index d9ac1aa2c2..ccd6be2baa 100755
--- a/activemq-core/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java
+++ b/activemq-core/src/main/java/org/apache/activemq/network/jms/DestinationBridge.java
@@ -79,7 +79,7 @@ abstract class DestinationBridge implements Service,MessageListener{
 
    
     protected Destination processReplyToDestination (Destination destination){
-        return jmsConnector.createReplyToBridge(destination, getConsumerConnection(), getProducerConnection());
+        return jmsConnector.createReplyToBridge(destination, getConnnectionForConsumer(), getConnectionForProducer());
     }
     
     public void start() throws Exception{
@@ -140,9 +140,9 @@ abstract class DestinationBridge implements Service,MessageListener{
 
     protected abstract void sendMessage(Message message) throws JMSException;
 
-    protected abstract Connection getConsumerConnection();
+    protected abstract Connection getConnnectionForConsumer();
     
-    protected abstract Connection getProducerConnection();
+    protected abstract Connection getConnectionForProducer();
 
     
 }
\ No newline at end of file
diff --git a/activemq-core/src/main/java/org/apache/activemq/network/jms/QueueBridge.java b/activemq-core/src/main/java/org/apache/activemq/network/jms/QueueBridge.java
index 2f1882eec0..4ffaa97c30 100755
--- a/activemq-core/src/main/java/org/apache/activemq/network/jms/QueueBridge.java
+++ b/activemq-core/src/main/java/org/apache/activemq/network/jms/QueueBridge.java
@@ -16,6 +16,7 @@
  */
 package org.apache.activemq.network.jms;
 
+import javax.jms.Connection;
 import javax.jms.Destination;
 import javax.jms.JMSException;
 import javax.jms.Message;
@@ -153,5 +154,13 @@ class QueueBridge extends DestinationBridge{
         this.selector=selector;
     }
     
+    protected Connection getConnnectionForConsumer(){
+        return getConsumerConnection();
+    }
+    
+    protected Connection getConnectionForProducer(){
+        return getProducerConnection();
+    }
+    
   
 }
\ No newline at end of file
diff --git a/activemq-core/src/main/java/org/apache/activemq/network/jms/TopicBridge.java b/activemq-core/src/main/java/org/apache/activemq/network/jms/TopicBridge.java
index 66315d9cc9..d987052e54 100755
--- a/activemq-core/src/main/java/org/apache/activemq/network/jms/TopicBridge.java
+++ b/activemq-core/src/main/java/org/apache/activemq/network/jms/TopicBridge.java
@@ -16,6 +16,7 @@
  */
 package org.apache.activemq.network.jms;
 
+import javax.jms.Connection;
 import javax.jms.Destination;
 import javax.jms.JMSException;
 import javax.jms.Message;
@@ -176,4 +177,12 @@ class TopicBridge extends DestinationBridge{
     public void setSelector(String selector){
         this.selector=selector;
     }
+    
+    protected Connection getConnnectionForConsumer(){
+        return getConsumerConnection();
+    }
+    
+    protected Connection getConnectionForProducer(){
+        return getProducerConnection();
+    }
 }
\ No newline at end of file