svn commit: r477726 - /webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java

[mlovett]

Author: mlovett
Date: Tue Nov 21 08:16:58 2006
New Revision: 477726

URL: http://svn.apache.org/viewvc?view=rev&rev=477726
Log:
Minor trace updates to SenderWorker

Modified:
    
webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java

Modified: 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java?view=diff&rev=477726&r1=477725&r2=477726
==============================================================================
--- 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java
 (original)
+++ 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java
 Tue Nov 21 08:16:58 2006
@@ -326,26 +326,28 @@
        
        private boolean isAckPiggybackableMsgType(int messageType) {
                if (log.isDebugEnabled())
-                       log.debug("Enter: Sender::isAckPiggybackableMsgType, " 
+ messageType);
+                       log.debug("Enter: 
SenderWorker::isAckPiggybackableMsgType, " + messageType);
                boolean piggybackable = true;
 
                if (messageType == Sandesha2Constants.MessageTypes.ACK)
                        piggybackable = false;
 
                if (log.isDebugEnabled())
-                       log.debug("Exit: Sender::isAckPiggybackableMsgType, " + 
piggybackable);
+                       log.debug("Exit: 
SenderWorker::isAckPiggybackableMsgType, " + piggybackable);
                return piggybackable;
        }
        
        private void checkForSyncResponses(MessageContext msgCtx) throws 
SandeshaException {
                if (log.isDebugEnabled())
-                       log.debug("Enter: Sender::checkForSyncResponses, " + 
msgCtx.getEnvelope().getHeader());
+                       log.debug("Enter: SenderWorker::checkForSyncResponses, 
" + msgCtx.getEnvelope().getHeader());
 
                try {
 
                        boolean responsePresent = 
(msgCtx.getProperty(MessageContext.TRANSPORT_IN) != null);
-                       if (!responsePresent)
+                       if (!responsePresent) {
+                               if(log.isDebugEnabled()) log.debug("Exit: 
SenderWorker::checkForSyncResponses, no response present");
                                return;
+                       }
 
                        // create the responseMessageContext
 
@@ -420,21 +422,21 @@
                        throw new SandeshaException(message, e);
                }
                if (log.isDebugEnabled())
-                       log.debug("Exit: Sender::checkForSyncResponses");
+                       log.debug("Exit: SenderWorker::checkForSyncResponses");
        }
        
        private boolean isFaultEnvelope(SOAPEnvelope envelope) {
                if (log.isDebugEnabled())
-                       log.debug("Enter: Sender::isFaultEnvelope, " + 
envelope.getBody().getFault());
+                       log.debug("Enter: SenderWorker::isFaultEnvelope, " + 
envelope.getBody().getFault());
                SOAPFault fault = envelope.getBody().getFault();
                if (fault != null) {
                        if (log.isDebugEnabled())
-                               log.debug("Exit: Sender::isFaultEnvelope, 
TRUE");
+                               log.debug("Exit: SenderWorker::isFaultEnvelope, 
TRUE");
                        return true;
                }
 
                if (log.isDebugEnabled())
-                       log.debug("Exit: Sender::isFaultEnvelope, FALSE");
+                       log.debug("Exit: SenderWorker::isFaultEnvelope, FALSE");
                return false;
        }
 



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]