Author: chamikara
Date: Mon Oct 31 22:37:11 2005
New Revision: 329992
URL: http://svn.apache.org/viewcvs?rev=329992&view=rev
Log:
Users can set the SANDESHA_DEBUG_MODE to 'on' in the client code and Sandesha
will print various RM related details (e.g. the messages that get exchanged,
messages sent by the Sender, messages invoked by the Invoker).
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java?rev=329992&r1=329991&r2=329992&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
(original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java Mon Oct
31 22:37:11 2005
@@ -259,4 +259,6 @@
String RM_ENABLE_KEY = "RMEnabled";
+ String SANDESHA_DEBUG_MODE = "SandeshaDebugMode";
+
}
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java?rev=329992&r1=329991&r2=329992&view=diff
==============================================================================
---
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
(original)
+++
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
Mon Oct 31 22:37:11 2005
@@ -28,6 +28,7 @@
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.handlers.AbstractHandler;
import org.apache.sandesha2.Constants;
@@ -54,9 +55,20 @@
RMMsgContext rmMessageContext = MsgInitializer
.initializeMessage(msgContext);
+ ConfigurationContext context =
rmMessageContext.getMessageContext().getSystemContext();
+
+ Object debug =
context.getProperty(Constants.SANDESHA_DEBUG_MODE);
+ if (debug!=null && "on".equals(debug)) {
+ System.out.println("DEBUG:
SandeshaGlobalInHandler got a '" +
SandeshaUtil.getMessageTypeString(rmMessageContext.getMessageType())+ "'
message.");
+ }
+
//Dropping duplicates
boolean dropped = dropIfDuplicate (rmMessageContext);
if (dropped) {
+ if (debug!=null && "on".equals(debug)) {
+ System.out.println("DEBUG:
SandeshaGlobalInHandler DROPPED a '" +
SandeshaUtil.getMessageTypeString(rmMessageContext.getMessageType())+ "'
message.");
+ }
+
processDroppedMessage (rmMessageContext);
return;
}
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java?rev=329992&r1=329991&r2=329992&view=diff
==============================================================================
---
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
(original)
+++
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
Mon Oct 31 22:37:11 2005
@@ -81,6 +81,11 @@
} catch (SandeshaException ex) {
throw new AxisFault("Cant initialize the message");
}
+
+ Object debug =
context.getProperty(Constants.SANDESHA_DEBUG_MODE);
+ if (debug!=null && "on".equals(debug)) {
+ System.out.println("DEBUG: SandeshaInHandler got a '" +
SandeshaUtil.getMessageTypeString(rmMsgCtx.getMessageType())+ "' message.");
+ }
MsgProcessor msgProcessor = MsgProcessorFactory
.getMessageProcessor(rmMsgCtx.getMessageType());
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java?rev=329992&r1=329991&r2=329992&view=diff
==============================================================================
---
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
(original)
+++
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
Mon Oct 31 22:37:11 2005
@@ -116,6 +116,10 @@
msgCtx.setProperty(Constants.APPLICATION_PROCESSING_DONE,
"true");
+ Object debug =
context.getProperty(Constants.SANDESHA_DEBUG_MODE);
+ if (debug!=null && "on".equals(debug)) {
+ System.out.println("DEBUG: SandeshaOutHandler got a '"
+ SandeshaUtil.getMessageTypeString(rmMsgCtx.getMessageType())+ "' message.");
+ }
//TODO recheck
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java?rev=329992&r1=329991&r2=329992&view=diff
==============================================================================
---
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java
(original)
+++
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java
Mon Oct 31 22:37:11 2005
@@ -137,6 +137,11 @@
//Invoking the message.
new AxisEngine
(msgToInvoke.getSystemContext()).receive(msgToInvoke);
+ Object debug =
context.getProperty(Constants.SANDESHA_DEBUG_MODE);
+ if (debug!=null &&
"on".equals(debug)) {
+
System.out.println("DEBUG: Invoker invoking a '" +
SandeshaUtil.getMessageTypeString(rmMsg.getMessageType())+ "' message.");
+ }
+
//deleting the message
entry.
storageMapMgr.delete(key);
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java?rev=329992&r1=329991&r2=329992&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java
(original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java Mon
Oct 31 22:37:11 2005
@@ -100,7 +100,13 @@
.initializeMessage(msgCtx);
updateMessage(msgCtx);
+ Object debug =
context.getProperty(Constants.SANDESHA_DEBUG_MODE);
+ if (debug!=null && "on".equals(debug)) {
+ System.out.println("DEBUG:
Sender is sending a '" +
SandeshaUtil.getMessageTypeString(rmMsgCtx.getMessageType())+ "' message.");
+ }
+
new AxisEngine(context).send(msgCtx);
+
//if (!msgCtx.isServerSide())
checkForSyncResponses(msgCtx);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
