[jboss-cvs] JBoss Messaging SVN: r3189 - trunk/src/main/org/jboss/jms/server/bridge.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2007-10-12 10:31:28 -0400 (Fri, 12 Oct 2007)
New Revision: 3189

Modified:
   trunk/src/main/org/jboss/jms/server/bridge/Bridge.java
Log:
http://jira.jboss.com/jira/browse/JBMESSAGING-999


Modified: trunk/src/main/org/jboss/jms/server/bridge/Bridge.java
===================================================================
--- trunk/src/main/org/jboss/jms/server/bridge/Bridge.java	2007-10-12 12:25:53 UTC (rev 3188)
+++ trunk/src/main/org/jboss/jms/server/bridge/Bridge.java	2007-10-12 14:31:28 UTC (rev 3189)
@@ -823,9 +823,7 @@
       
       return tm;
    }
-   
-   
-   
+         
    private Connection createConnection(String username, String password, ConnectionFactoryFactory cff)
       throws Exception
    {
@@ -866,8 +864,6 @@
          }  
       }
       
-      conn.setExceptionListener(new BridgeExceptionListener());
-      
       return conn;
    }
     
@@ -939,8 +935,7 @@
       	//Lookup the destinations
       	sourceDestination = sourceDestinationFactory.createDestination();
       	
-      	targetDestination = targetDestinationFactory.createDestination();
-      	      
+      	targetDestination = targetDestinationFactory.createDestination();      	      
          
          sourceConn = createConnection(sourceUsername, sourcePassword, sourceCff);
          
@@ -948,7 +943,7 @@
          {
             targetConn = createConnection(targetUsername, targetPassword, targetCff);
             
-          //  targetConn.setExceptionListener(exceptionListener); 
+            targetConn.setExceptionListener(new BridgeExceptionListener());            
          }
                   
          if (clientID != null)
@@ -956,7 +951,7 @@
             sourceConn.setClientID(clientID);
          }
          
-        // sourceConn.setExceptionListener(exceptionListener);         
+         sourceConn.setExceptionListener(new BridgeExceptionListener());         
           
          Session sess;