Author: chamikara
Date: Sun Oct 23 21:26:32 2005
New Revision: 327956
URL: http://svn.apache.org/viewcvs?rev=327956&view=rev
Log:
SandeshaOutHandler should start the listner when acks are async.
A Util method for giving the name of MessageType (can be used for debugging).
Modified:
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/util/SandeshaUtil.java
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=327956&r1=327955&r2=327956&view=diff
==============================================================================
---
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
(original)
+++
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
Sun Oct 23 21:26:32 2005
@@ -38,6 +38,7 @@
import org.apache.sandesha2.msgprocessors.MsgProcessor;
import org.apache.sandesha2.msgprocessors.MsgProcessorFactory;
import org.apache.sandesha2.storage.beanmanagers.SequencePropertyBeanMgr;
+import org.apache.sandesha2.util.SandeshaUtil;
/**
* @author Chamikara
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=327956&r1=327955&r2=327956&view=diff
==============================================================================
---
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
(original)
+++
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
Sun Oct 23 21:26:32 2005
@@ -20,6 +20,7 @@
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.clientapi.ListenerManager;
import org.apache.axis2.context.AbstractContext;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.MessageContext;
@@ -185,6 +186,15 @@
try {
String acksTo = (String) context
.getProperty(Constants.AcksTo);
+
+ //If acksTo is not anonymous. Start the
listner TODO: verify
+ if
(!Constants.WSA.NS_URI_ANONYMOUS.equals(acksTo)) {
+ String transportIn = (String)
context.getProperty(MessageContext.TRANSPORT_IN);
+ if (transportIn==null)
+ transportIn =
org.apache.axis2.Constants.TRANSPORT_HTTP;
+
ListenerManager.makeSureStarted(transportIn,context);
+ }
+
addCreateSequenceMessage(rmMsgCtx,
tempSequenceId, acksTo);
} catch (SandeshaException e1) {
throw new AxisFault(e1.getMessage());
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/util/SandeshaUtil.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/util/SandeshaUtil.java?rev=327956&r1=327955&r2=327956&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/util/SandeshaUtil.java
(original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/util/SandeshaUtil.java
Sun Oct 23 21:26:32 2005
@@ -393,4 +393,23 @@
}
}
+
+ public static String getMessageTypeString (int messageType) {
+ switch (messageType) {
+ case Constants.MessageTypes.CREATE_SEQ:
+ return "CreateSequence";
+ case Constants.MessageTypes.CREATE_SEQ_RESPONSE:
+ return "CreateSequenceResponse";
+ case Constants.MessageTypes.ACK:
+ return "Acknowledgement";
+ case Constants.MessageTypes.APPLICATION:
+ return "Application";
+ case Constants.MessageTypes.TERMINATE_SEQ:
+ return "TerminateSequence";
+ case Constants.MessageTypes.UNKNOWN:
+ return "Unknown";
+ default:
+ return "Error";
+ }
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
