You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ml...@apache.org on 2006/11/21 17:16:59 UTC
svn commit: r477726 -
/webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org