Author: damitha
Date: Thu Aug 28 13:40:35 2008
New Revision: 689974
URL: http://svn.apache.org/viewvc?rev=689974&view=rev
Log: (empty)
Modified:
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/include/sandesha2_app_msg_processor.h
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/handlers/sandesha2_in_handler.c
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/include/sandesha2_app_msg_processor.h
URL:
http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/include/sandesha2_app_msg_processor.h?rev=689974&r1=689973&r2=689974&view=diff
==============================================================================
---
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/include/sandesha2_app_msg_processor.h
(original)
+++
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/include/sandesha2_app_msg_processor.h
Thu Aug 28 13:40:35 2008
@@ -58,8 +58,7 @@
axis2_char_t *rmd_sequence_id,
struct sandesha2_storage_mgr *storage_mgr,
struct sandesha2_sender_mgr *sender_mgr,
- struct sandesha2_seq_property_mgr *seq_prop_mgr,
- axis2_bool_t send_msg);
+ struct sandesha2_seq_property_mgr *seq_prop_mgr);
/** @} */
#ifdef __cplusplus
Modified:
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/handlers/sandesha2_in_handler.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/handlers/sandesha2_in_handler.c?rev=689974&r1=689973&r2=689974&view=diff
==============================================================================
---
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/handlers/sandesha2_in_handler.c
(original)
+++
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/handlers/sandesha2_in_handler.c
Thu Aug 28 13:40:35 2008
@@ -400,7 +400,7 @@
sandesha2_seq_property_mgr_update(seq_prop_mgr, env,
rcvd_msgs_bean);
app_msg_processor =
sandesha2_app_msg_processor_create(env);
sandesha2_app_msg_processor_send_ack_if_reqd(env,
rm_msg_ctx, bean_value,
- rmd_sequence_id, storage_mgr, sender_mgr,
seq_prop_mgr, AXIS2_FALSE);
+ rmd_sequence_id, storage_mgr, sender_mgr,
seq_prop_mgr);
sandesha2_msg_processor_free(app_msg_processor, env);
}
}
@@ -539,7 +539,7 @@
{
app_msg_processor =
sandesha2_app_msg_processor_create(env);
sandesha2_app_msg_processor_send_ack_if_reqd(env,
rm_msg_ctx, rcvd_msgs_str,
- rmd_sequence_id, storage_mgr, sender_mgr,
seq_prop_mgr, AXIS2_FALSE);
+ rmd_sequence_id, storage_mgr, sender_mgr,
seq_prop_mgr);
sandesha2_msg_processor_free(app_msg_processor, env);
}
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=689974&r1=689973&r2=689974&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 13:40:35 2008
@@ -743,7 +743,7 @@
"[sandesha2] Got WSRM 1.0 last message. Send ack and
aborting");
sandesha2_app_msg_processor_send_ack_if_reqd(env, rm_msg_ctx,
msgs_str, rmd_sequence_id,
- storage_mgr, sender_mgr, seq_prop_mgr, AXIS2_FALSE);
+ storage_mgr, sender_mgr, seq_prop_mgr);
temp_svc = axis2_msg_ctx_get_svc(app_msg_ctx, env);
if(temp_svc)
@@ -919,7 +919,7 @@
}
if(!sandesha2_app_msg_processor_send_ack_if_reqd(env, rm_msg_ctx,
msgs_str, rmd_sequence_id, storage_mgr,
- sender_mgr, seq_prop_mgr, AXIS2_FALSE))
+ sender_mgr, seq_prop_mgr))
{
AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "[sandesha2] Sending
acknowledgment failed");
@@ -1788,8 +1788,7 @@
axis2_char_t *rmd_sequence_id,
sandesha2_storage_mgr_t *storage_mgr,
sandesha2_sender_mgr_t *sender_mgr,
- sandesha2_seq_property_mgr_t *seq_prop_mgr,
- axis2_bool_t send_msg)
+ sandesha2_seq_property_mgr_t *seq_prop_mgr)
{
/*axis2_endpoint_ref_t *to_epr = NULL;
axis2_endpoint_ref_t *temp_to_epr = NULL;*/
@@ -1879,7 +1878,7 @@
is_anonymous_reply_to = !reply_to_addr || (reply_to_addr &&
sandesha2_utils_is_anon_uri(env, reply_to_addr));
/*if(sandesha2_utils_is_rm_1_0_anonymous_acks_to(env, rm_version,
acks_to_str)
&& is_anonymous_reply_to && !one_way)*/
- if(sandesha2_utils_is_anon_uri(env, acks_to_str) && is_anonymous_reply_to
&& !one_way && !send_msg)
+ if(sandesha2_utils_is_anon_uri(env, acks_to_str) && is_anonymous_reply_to
&& !one_way)
{
/* This means acknowledgment address is anomymous and RM version is
1.0. Flow comes to
* this block only in the server side.
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
