[jboss-cvs] JBoss Messaging SVN: r8421 - branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery.

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

Author: gaohoward
Date: 2011-08-16 03:06:15 -0400 (Tue, 16 Aug 2011)
New Revision: 8421

Modified:
   branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/ClusteredMessagingXAResourceRecovery.java
   branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/MessagingXAResourceWrapper2.java
Log:
remove debug logs


Modified: branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/ClusteredMessagingXAResourceRecovery.java
===================================================================
--- branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/ClusteredMessagingXAResourceRecovery.java	2011-08-16 07:00:12 UTC (rev 8420)
+++ branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/ClusteredMessagingXAResourceRecovery.java	2011-08-16 07:06:15 UTC (rev 8421)
@@ -78,15 +78,12 @@
    public ClusteredMessagingXAResourceRecovery()
    {
       if(trace) log.trace("Constructing BridgeXAResourceRecovery2");
-      log.error(this + " xxxxxxxx constructing XAre2");
    }
 
    public boolean initialise(String config)
    {
       if (log.isTraceEnabled()) { log.trace(this + " intialise: " + config); }
       
-      log.error(this + " xxxxxxx initializing ...");
-      
       StringTokenizer tok = new StringTokenizer(config, ",");
       
       //First (mandatory) param is the provider adaptor name
@@ -127,8 +124,6 @@
    {
       if (log.isTraceEnabled()) { log.trace(this + " hasMoreResources"); }
       
-      log.error(this + " xxxxxxx hasMore res " + resources);
-      
       if (iterator == null)
       {
          shutdownResources();
@@ -137,12 +132,9 @@
       
       if (iterator.hasNext())
       {
-         log.error(this + " xxxxxxx yes we have");
          return true;
       }
       
-      log.error(this + " xxxxxxx no we dont");
-      
       iterator = null;
       
       return false;
@@ -152,14 +144,11 @@
    {
       if (log.isTraceEnabled()) { log.trace(this + " getXAResource"); }
       
-      log.error(this + " xxxxxxx getXARes called");
-      
       return iterator.next();
    }
    
    protected void finalize()
    {
-      log.error(this + " xxxxxxxxxxxxxxx finalize called");
       shutdownResources(); 
    }
    
@@ -267,8 +256,6 @@
    {
       if (log.isTraceEnabled()) { log.trace(this + " look up CF via provider " + providerAdaptorName); }
       
-      log.error(this + " xxxxxxx look up CF via provider " + providerAdaptorName);
-      
       Context ctx = new InitialContext();
       
       JMSProviderAdapter adapter = (JMSProviderAdapter) ctx.lookup(providerAdaptorName);
@@ -277,15 +264,12 @@
       if (connectionFactoryRef == null)
          throw new IllegalStateException("Provider '" + providerAdaptorName + "' has no FactoryRef");
       
-      log.error(this + " xxxxxxx connectionFactoryRef: " + connectionFactoryRef);
-      
       // Lookup the connection factory
       ctx = adapter.getInitialContext();
 
       try
       {
          JBossConnectionFactory factory = (JBossConnectionFactory)Util.lookup(ctx, connectionFactoryRef, JBossConnectionFactory.class);
-         log.error(this + " xxxxxxx got bare facotry " + factory);
 
          return factory;
       }

Modified: branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/MessagingXAResourceWrapper2.java
===================================================================
--- branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/MessagingXAResourceWrapper2.java	2011-08-16 07:00:12 UTC (rev 8420)
+++ branches/JBMESSAGING_1890/src/main/org/jboss/jms/server/recovery/MessagingXAResourceWrapper2.java	2011-08-16 07:06:15 UTC (rev 8421)
@@ -64,14 +64,10 @@
    {
       try
       {
-         log.error(this + " xxxxxx construct wrapper delegate: " + connectionDelegate + " node " + node);
-         
          connection = connectionDelegate;
          ClientSessionDelegate session = (ClientSessionDelegate)connection.createSessionDelegate(true, Session.SESSION_TRANSACTED, true);
          delegate = session.getXAResource();
          
-         log.error(this + " xxxxxxxxx get XAResource delegate: " + delegate);
-         
          this.node = node;
          connection.setExceptionListener(this);
       }
@@ -215,7 +211,6 @@
     */
    public void close()
    {
-      log.error(this + " xxxxxxxxXXXXXXXxxxxxxxx cleaning up myself 9....");
       try
       {
          if (connection != null)