[hornetq-commits] JBoss hornetq SVN: r10829 - branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-06-16 21:52:22 -0400 (Thu, 16 Jun 2011)
New Revision: 10829

Modified:
   branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java
Log:
debug & trace

Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java
===================================================================
--- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java	2011-06-17 01:51:33 UTC (rev 10828)
+++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java	2011-06-17 01:52:22 UTC (rev 10829)
@@ -35,6 +35,7 @@
 import org.hornetq.core.postoffice.BindingType;
 import org.hornetq.core.server.Queue;
 import org.hornetq.core.server.ServerMessage;
+import org.hornetq.core.server.cluster.ClusterConnection;
 import org.hornetq.core.server.cluster.MessageFlowRecord;
 import org.hornetq.core.server.cluster.Transformer;
 import org.hornetq.utils.UUID;
@@ -53,6 +54,8 @@
    private static final Logger log = Logger.getLogger(ClusterConnectionBridge.class);
    
    private static final boolean isTrace = log.isTraceEnabled();
+   
+   private final ClusterConnection clusterConnection;
 
    private final MessageFlowRecord flowRecord;
 
@@ -64,11 +67,10 @@
 
    private final SimpleString idsHeaderName;
 
-   private final TransportConfiguration connector;
-
    private final String targetNodeID;
 
-   public ClusterConnectionBridge(final ServerLocatorInternal serverLocator,
+   public ClusterConnectionBridge(final ClusterConnection clusterConnection,
+                                  final ServerLocatorInternal serverLocator,
                                   final int reconnectAttempts,
                                   final long retryInterval,
                                   final double retryMultiplier,
@@ -112,12 +114,13 @@
             storageManager);
 
       idsHeaderName = MessageImpl.HDR_ROUTE_TO_IDS.concat(name);
+      
+      this.clusterConnection = clusterConnection;
 
       this.targetNodeID = targetNodeID;
       this.managementAddress = managementAddress;
       this.managementNotificationAddress = managementNotificationAddress;
       this.flowRecord = flowRecord;
-      this.connector = connector;
       
       // we need to disable DLQ check on the clustered bridges
       queue.setInternalQueue(true);
@@ -156,6 +159,7 @@
 
    private void setupNotificationConsumer() throws Exception
    {
+      log.debug("Setting up notificationConsumer for " + flowRecord + " on bridge " + this.getName());
       if (flowRecord != null)
       {
          flowRecord.reset();
@@ -164,6 +168,7 @@
          {
             try
             {
+               log.debug("Closing notification Consumer for reopening " + notifConsumer + " on bridge " + this.getName());
                notifConsumer.close();
 
                notifConsumer = null;
@@ -224,6 +229,11 @@
 
          ClientProducer prod = session.createProducer(managementAddress);
 
+         if (log.isDebugEnabled())
+         {
+            log.debug("Cluster connetion bridge on " + clusterConnection + " requesting information on queues");
+         }
+         
          prod.send(message);
       }
    }
@@ -242,6 +252,7 @@
    
    protected void failed(final boolean permanently)
    {
+      log.debug("Cluster Bridge " + this.getName() + " failed, permanently=" + permanently);
       super.fail(permanently);
       
       if (permanently)