svn commit: r480067 - in /webservices/sandesha/trunk/java/src/org/apache/sandesha2: handlers/SandeshaOutHandler.java msgprocessors/AcknowledgementProcessor.java

[mlovett]

Author: mlovett
Date: Tue Nov 28 06:34:02 2006
New Revision: 480067

URL: http://svn.apache.org/viewvc?view=rev&rev=480067
Log:
Add trace statements

Modified:
    
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
    
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java

Modified: 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java?view=diff&rev=480067&r1=480066&r2=480067
==============================================================================
--- 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
 (original)
+++ 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
 Tue Nov 28 06:34:02 2006
@@ -132,6 +132,7 @@
 
                        MsgProcessor msgProcessor = null;
                        int messageType = rmMsgCtx.getMessageType();
+                       if(log.isDebugEnabled()) log.debug("Message Type: " + 
messageType);
                        if (messageType == 
Sandesha2Constants.MessageTypes.UNKNOWN) {
                                MessageContext requestMsgCtx = 
msgCtx.getOperationContext().getMessageContext(
                                                
OperationContextFactory.MESSAGE_LABEL_IN_VALUE);

Modified: 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java?view=diff&rev=480067&r1=480066&r2=480067
==============================================================================
--- 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java
 (original)
+++ 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java
 Tue Nov 28 06:34:02 2006
@@ -121,6 +121,7 @@
                
                String internalSequenceId = 
SandeshaUtil.getSequenceProperty(outSequenceId,
                                
Sandesha2Constants.SequenceProperties.INTERNAL_SEQUENCE_ID, storageManager);
+               if(log.isDebugEnabled()) log.debug("Got ack for RM Sequence: " 
+ outSequenceId + ", internal id: " + internalSequenceId);
 
                //here we cannot get the property key using the usual 
SandeshaUtil.getSequencePropertyKey function,
                //because this can be a applicationMessage, which piggybacks 
the acknowledgement.
@@ -160,6 +161,7 @@
                        AcknowledgementRange ackRange = (AcknowledgementRange) 
ackRangeIterator.next();
                        long lower = ackRange.getLowerValue();
                        long upper = ackRange.getUpperValue();
+                       if(log.isDebugEnabled()) log.debug("Ack Range: " + 
lower + " - " + upper);
 
                        for (long messageNo = lower; messageNo <= upper; 
messageNo++) {
                                SenderBean retransmitterBean = 
getRetransmitterEntry(retransmitterEntriesOfSequence, messageNo);



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