[jboss-cvs] JBoss Messaging SVN: r2322 - in trunk/src/main/org/jboss/jms: server/endpoint and 1 other directory.

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

Author: ovidiu.feodorov at jboss.com
Date: 2007-02-15 03:43:05 -0500 (Thu, 15 Feb 2007)
New Revision: 2322

Modified:
   trunk/src/main/org/jboss/jms/client/container/FailoverValveInterceptor.java
   trunk/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java
Log:
improved logging

Modified: trunk/src/main/org/jboss/jms/client/container/FailoverValveInterceptor.java
===================================================================
--- trunk/src/main/org/jboss/jms/client/container/FailoverValveInterceptor.java	2007-02-15 07:46:08 UTC (rev 2321)
+++ trunk/src/main/org/jboss/jms/client/container/FailoverValveInterceptor.java	2007-02-15 08:43:05 UTC (rev 2322)
@@ -120,10 +120,9 @@
       }
       catch (MessagingNetworkFailureException e)
       {
-         log.debug(this + " putting " + methodName + "() on hold until failover completes");
+         log.debug(this + " detected network failure, putting " + methodName +
+            "() on hold until failover completes");
          
-         log.info("********** CAUGHT NETWORK FAILURE");
-         
          fcc.failureDetected(e, this, remotingConnection);
          
          log.debug(this + " resuming " + methodName + "()");

Modified: trunk/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java
===================================================================
--- trunk/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java	2007-02-15 07:46:08 UTC (rev 2321)
+++ trunk/src/main/org/jboss/jms/server/endpoint/ServerConnectionEndpoint.java	2007-02-15 08:43:05 UTC (rev 2322)
@@ -610,6 +610,8 @@
    
    void sendMessage(JBossMessage msg, Transaction tx, boolean checkForDuplicates) throws Exception
    {
+      if (trace) { log.trace(this + " sending " + msg + (tx == null ? " non-transactionally" : " in " + tx)); }
+
       JBossDestination dest = (JBossDestination)msg.getJMSDestination();
       
       // This allows the no-local consumers to filter out the messages that come from the same
@@ -657,7 +659,7 @@
          {
             if (!postOffice.route(ref, new JMSCondition(true, dest.getName()), tx))
             {
-               throw new JMSException("Failed to route message");
+               throw new JMSException("Failed to route " + ref + " to " + dest.getName());
             }
          }
          else