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 da...@apache.org on 2008/08/29 00:32:02 UTC
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)
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org