You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ml...@apache.org on 2006/11/28 15:34:03 UTC
svn commit: r480067 - in
/webservices/sandesha/trunk/java/src/org/apache/sandesha2:
handlers/SandeshaOutHandler.java msgprocessors/AcknowledgementProcessor.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org