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/22 15:16:01 UTC
svn commit: r688079 - in
/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008:
config/module.xml src/msgprocessors/app_msg_processor.c
src/msgprocessors/create_seq_res_msg_processor.c src/util/terminate_mgr.c
Author: damitha
Date: Fri Aug 22 06:16:00 2008
New Revision: 688079
URL: http://svn.apache.org/viewvc?rev=688079&view=rev
Log:
Now rm 1.0 sandesha2/C client interops with .net
Modified:
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/config/module.xml
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/app_msg_processor.c
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c
webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/util/terminate_mgr.c
Modified: webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/config/module.xml
URL: http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/config/module.xml?rev=688079&r1=688078&r2=688079&view=diff
==============================================================================
--- webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/config/module.xml (original)
+++ webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/config/module.xml Fri Aug 22 06:16:00 2008
@@ -70,7 +70,7 @@
<parameter name="sandesha2_db" locked="false">/tmp/sandesha2_db</parameter>
<!-- General parameters -->
<parameter name="ExponentialBackoff" locked="false">AXIS2_FALSE</parameter>
- <parameter name="RetransmissionInterval" locked="false">4</parameter><!--In seconds-->
+ <parameter name="RetransmissionInterval" locked="false">8</parameter><!--In seconds-->
<parameter name="InactivityTimeout" locked="false">64</parameter><!--In seconds-->
<parameter name="StorageManager" locked="false">persistent</parameter>
<parameter name="InvokeInOrder" locked="false">AXIS2_FALSE</parameter>
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=688079&r1=688078&r2=688079&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 Fri Aug 22 06:16:00 2008
@@ -2425,6 +2425,8 @@
AXIS2_SLEEP(retrans_interval);
+ AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "dam_internal_sequence_id:%s", internal_sequence_id);
+
rms_sequence_bean = sandesha2_seq_property_mgr_retrieve(seq_prop_mgr, env, internal_sequence_id,
SANDESHA2_SEQUENCE_PROPERTY_RMS_SEQ_ID);
@@ -2433,7 +2435,7 @@
transport_sender = axis2_transport_out_desc_get_sender(transport_out, env);
- while(rms_sequence_bean)
+ while(!rms_sequence_bean)
{
continue_sending = sandesha2_msg_retrans_adjuster_adjust_retrans(env, create_sequence_sender_bean,
conf_ctx, storage_mgr, seq_prop_mgr, create_seq_mgr, sender_mgr);
Modified: webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c?rev=688079&r1=688078&r2=688079&view=diff
==============================================================================
--- webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c (original)
+++ webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/msgprocessors/create_seq_res_msg_processor.c Fri Aug 22 06:16:00 2008
@@ -278,6 +278,10 @@
SANDESHA2_SEQUENCE_PROPERTY_RMS_SEQ_ID, rms_sequence_id);
if(rms_sequence_bean)
{
+ AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI,
+ "[sandesha2] Inserting rms_sequence_bean with rms_sequence_id :%s and internal_sequence_id :%s",
+ rms_sequence_id, internal_sequence_id);
+
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, rms_sequence_bean);
sandesha2_seq_property_bean_free(rms_sequence_bean, env);
}
Modified: webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/util/terminate_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/util/terminate_mgr.c?rev=688079&r1=688078&r2=688079&view=diff
==============================================================================
--- webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/util/terminate_mgr.c (original)
+++ webservices/sandesha/tags/sandesha2/c/worker_thread_removed-23may2008/src/util/terminate_mgr.c Fri Aug 22 06:16:00 2008
@@ -991,8 +991,8 @@
}
/* Clean sending side data */
- /*sandesha2_terminate_mgr_terminate_sending_side(env, conf_ctx, internal_sequence_id,
- is_svr_side, storage_mgr, seq_prop_mgr, create_seq_mgr, sender_mgr);*/
+ sandesha2_terminate_mgr_terminate_sending_side(env, conf_ctx, internal_sequence_id,
+ is_svr_side, storage_mgr, seq_prop_mgr, create_seq_mgr, sender_mgr);
terminate_added = sandesha2_seq_property_bean_create(env);
if(terminate_added)
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org