[prev in list] [next in list] [prev in thread] [next in thread]
List: sandesha-dev
Subject: svn commit: r599669 - in /webservices/sandesha/trunk/c:
From: damitha () apache ! org
Date: 2007-11-30 1:47:59
Message-ID: 20071130014800.2D3CF1A9832 () eris ! apache ! org
[Download RAW message or body]
Author: damitha
Date: Thu Nov 29 17:47:56 2007
New Revision: 599669
URL: http://svn.apache.org/viewvc?rev=599669&view=rev
Log:
There was a problem of if previous sequence is abruptly stopped, the next sequence \
send duplicate application messages. Fixed this.
Modified:
webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c
webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c
webservices/sandesha/trunk/c/src/storage/sqlite/permanent_sender_mgr.c
Modified: webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c?rev=599669&r1=599668&r2=599669&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c (original)
+++ webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c Thu Nov 29 \
17:47:56 2007 @@ -99,7 +99,6 @@
client_home = AXIS2_GETENV("AXIS2C_HOME");
if (!client_home)
client_home = "../../deploy";
-
/* Create service client */
svc_client = axis2_svc_client_create(env, client_home);
if (!svc_client)
Modified: webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c?rev=599669&r1=599668&r2=599669&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c Thu Nov 29 \
17:47:56 2007 @@ -230,6 +230,7 @@
axis2_msg_ctx_set_property(msg_ctx, env, SANDESHA2_ACK_PROCSSED, property);
input_bean = sandesha2_sender_bean_create(env);
+ sandesha2_sender_bean_set_internal_seq_id(input_bean, env, int_seq_id);
sandesha2_sender_bean_set_send(input_bean, env, AXIS2_TRUE);
sandesha2_sender_bean_set_resend(input_bean, env, AXIS2_TRUE);
retrans_list = sandesha2_sender_mgr_find_by_sender_bean(retrans_mgr, env,
@@ -262,6 +263,9 @@
env, retrans_list, j);
if(retrans_bean)
{
+ int msg_type = sandesha2_sender_bean_get_msg_type(retrans_bean, \
env); + AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI,
+ "[sandesha2]Removing the sender bean with type %d", msg_type);
sandesha2_sender_mgr_remove(retrans_mgr, env,
sandesha2_sender_bean_get_msg_id((sandesha2_rm_bean_t *)
retrans_bean, env));
Modified: webservices/sandesha/trunk/c/src/storage/sqlite/permanent_sender_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/sqlite/permanent_sender_mgr.c?rev=599669&r1=599668&r2=599669&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/sqlite/permanent_sender_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/sqlite/permanent_sender_mgr.c Thu Nov 29 \
17:47:56 2007 @@ -634,8 +634,6 @@
axutil_array_list_t *match_list = NULL;
sandesha2_permanent_sender_mgr_t *sender_mgr_impl = NULL;
sandesha2_sender_bean_t *result = NULL;
- AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "[sandesha2]Entry:sandesha2_"\
- "permanent_sender_mgr_get_next_msg_to_send");
AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, "[sandesha2]Entry:sandesha2_"\
"permanent_sender_mgr_get_next_msg_to_send");
sender_mgr_impl = SANDESHA2_INTF_TO_IMPL(sender_mgr);
@@ -684,6 +682,8 @@
break;
}
}
+ AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, "[sandesha2]Exit:sandesha2_"\
+ "permanent_sender_mgr_get_next_msg_to_send");
return result;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic