svn commit: r690029 - /webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c

Author: damitha
Date: Thu Aug 28 15:32:01 2008
New Revision: 690029

URL: http://svn.apache.org/viewvc?rev=690029&view=rev
Log:
Fixed SANDESHA2C-56

Modified:
    webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c

Modified: webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c?rev=690029&r1=690028&r2=690029&view=diff
==============================================================================
--- webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c (original)
+++ webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c Thu Aug 28 15:32:01 2008
@@ -738,6 +738,7 @@
         axis2_status_t status = AXIS2_FAILURE;
         axis2_bool_t send_response = AXIS2_TRUE;
         axis2_svc_t *temp_svc = NULL;
+        axis2_op_ctx_t *op_ctx = NULL;
 
         AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, 
                 "[sandesha2] Got WSRM 1.0 last message. Send ack and aborting");
@@ -745,6 +746,20 @@
         sandesha2_app_msg_processor_send_ack_if_reqd(env, rm_msg_ctx, msgs_str, rmd_sequence_id, 
                 storage_mgr, sender_mgr, seq_prop_mgr);
 
+        op_ctx = axis2_msg_ctx_get_op_ctx(app_msg_ctx, env);
+        if(op_ctx)
+        {
+            int mep = -1;
+            axis2_op_t *op = NULL;
+            
+            op = axis2_op_ctx_get_op(op_ctx, env);
+            mep = axis2_op_get_axis_specific_mep_const(op, env);
+            if(mep == AXIS2_MEP_CONSTANT_IN_ONLY)
+            {
+                send_response = AXIS2_FALSE;
+            }
+        }
+
         temp_svc = axis2_msg_ctx_get_svc(app_msg_ctx, env);
         if(temp_svc)
         {
@@ -1862,6 +1877,7 @@
     }
 
     one_way = AXIS2_MEP_CONSTANT_IN_ONLY == mep;
+    AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "MEP:%d", mep);
 
     rm_version = sandesha2_utils_get_rm_version(env, rmd_sequence_id, seq_prop_mgr);
     if(!rm_version)