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 ch...@apache.org on 2005/10/24 06:26:54 UTC
svn commit: r327956 - in
/webservices/sandesha/trunk/src/org/apache/sandesha2:
handlers/SandeshaInHandler.java handlers/SandeshaOutHandler.java
util/SandeshaUtil.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org