You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by da...@apache.org on 2006/11/13 13:31:34 UTC
svn commit: r474280 - in /webservices/sandesha/trunk/c:
samples/rm_echo/rm_echo_client.c src/msgprocessors/ack_msg_processor.c
src/msgprocessors/app_msg_processor.c
src/msgprocessors/create_seq_msg_processor.c
Author: damitha
Date: Mon Nov 13 04:31:34 2006
New Revision: 474280
URL: http://svn.apache.org/viewvc?view=rev&rev=474280
Log:
seq offer is now working
Modified:
webservices/sandesha/trunk/c/samples/rm_echo/rm_echo_client.c
webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c
webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c
webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c
Modified: webservices/sandesha/trunk/c/samples/rm_echo/rm_echo_client.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_echo/rm_echo_client.c?view=diff&rev=474280&r1=474279&r2=474280
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_echo/rm_echo_client.c (original)
+++ webservices/sandesha/trunk/c/samples/rm_echo/rm_echo_client.c Mon Nov 13 04:31:34 2006
@@ -136,9 +136,6 @@
"__OPERATION_OUT_IN__");
AXIS2_OPTIONS_SET_REPLY_TO(options, env, reply_to);
- property = axis2_property_create(env);
- AXIS2_PROPERTY_SET_SCOPE(property, env, AXIS2_SCOPE_APPLICATION);
- AXIS2_PROPERTY_SET_VALUE(property, env, AXIS2_VALUE_TRUE);
/* Set up deploy folder. It is from the deploy folder, the configuration is
* picked up using the axis2.xml file.
@@ -207,6 +204,9 @@
AXIS2_CALLBACK_SET_ON_COMPLETE(callback3, rm_echo_callback_on_complete);
AXIS2_CALLBACK_SET_ON_ERROR(callback3, rm_echo_callback_on_error);
payload = build_om_payload_for_echo_svc(env, "echo3", "sequence1");
+ property = axis2_property_create(env);
+ AXIS2_PROPERTY_SET_SCOPE(property, env, AXIS2_SCOPE_APPLICATION);
+ AXIS2_PROPERTY_SET_VALUE(property, env, AXIS2_VALUE_TRUE);
AXIS2_OPTIONS_SET_PROPERTY(options, env, "Sandesha2LastMessage",
property);
send_non_blocking(env, svc_client, options, NULL, callback3, payload,
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?view=diff&rev=474280&r1=474279&r2=474280
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c Mon Nov 13 04:31:34 2006
@@ -326,17 +326,21 @@
sandesha2_seq_property_bean_set_value(completed_bean, env, str_list);
sandesha2_seq_property_mgr_update(seq_prop_mgr, env, completed_bean);
+ printf("int_seq_id:%s###################################33\n", int_seq_id);
last_out_msg_no_str = sandesha2_utils_get_seq_property(env, int_seq_id,
SANDESHA2_SEQ_PROP_LAST_OUT_MESSAGE_NO, storage_mgr);
if(last_out_msg_no_str)
{
+ printf("last_out_msg_no_str:%s############################\n", last_out_msg_no_str);
long highest_out_msg_no = 0;
highest_out_msg_no = atol(last_out_msg_no_str);
if(highest_out_msg_no > 0)
{
+ printf("highest_out_msg_no:%ld############################\n", highest_out_msg_no);
axis2_bool_t completed = AXIS2_FALSE;
completed = sandesha2_ack_mgr_verify_seq_completion(env,
ack_range_list, highest_out_msg_no);
+ printf("completed:%d############################\n", completed);
if(completed)
sandesha2_terminate_mgr_add_terminate_seq_msg(env, rm_msg_ctx,
out_seq_id, int_seq_id, storage_mgr);
Modified: webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c?view=diff&rev=474280&r1=474279&r2=474280
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c Mon Nov 13 04:31:34 2006
@@ -607,6 +607,7 @@
SANDESHA2_CLIENT_LAST_MESSAGE, AXIS2_FALSE);
if(property)
last_app_msg = AXIS2_PROPERTY_GET_VALUE(property, env);
+ printf("last_app_msg:%s######################################\n", last_app_msg);
if(last_app_msg && 0 == AXIS2_STRCMP(last_app_msg,
SANDESHA2_VALUE_TRUE))
last_msg = AXIS2_TRUE;
@@ -660,6 +661,7 @@
msg_number_str);
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env,
res_highest_msg_bean);
+ printf("last_msg:%d########################################\n", last_msg);
if(last_msg)
{
sandesha2_seq_property_bean_t *res_highest_msg_key_bean = NULL;
@@ -669,6 +671,7 @@
env, internal_seq_id,
SANDESHA2_SEQ_PROP_HIGHEST_OUT_MSG_KEY,
storage_key);
+ printf("internal_seq_id########################################:%s\n", internal_seq_id);
res_last_msg_key_bean = sandesha2_seq_property_bean_create_with_data(
env, internal_seq_id,
SANDESHA2_SEQ_PROP_LAST_OUT_MESSAGE_NO,
@@ -678,7 +681,6 @@
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env,
res_last_msg_key_bean);
}
- printf("internal_seq_id:%s###################################33\n", internal_seq_id);
out_seq_bean = sandesha2_seq_property_mgr_retrieve(seq_prop_mgr, env,
internal_seq_id, SANDESHA2_SEQ_PROP_OUT_SEQ_ID);
if(is_svr_side)
@@ -743,7 +745,6 @@
}
if(send_create_seq)
{
- printf("came1################################################\n");
sandesha2_seq_property_bean_t *res_create_seq_added = NULL;
axis2_char_t *addr_ns_uri = NULL;
axis2_char_t *anon_uri = NULL;
@@ -757,7 +758,6 @@
anon_uri = sandesha2_spec_specific_consts_get_anon_uri(env, addr_ns_uri);
if(!res_create_seq_added)
{
- printf("came2################################################\n");
axis2_char_t *acks_to = NULL;
res_create_seq_added = sandesha2_seq_property_bean_create_with_data(
@@ -1161,7 +1161,6 @@
env, AXIS2_WSDL_MESSAGE_LABEL_IN_VALUE);
if(req_msg)
{
- printf("******************************found req_msg********************************\n");
reply_to = AXIS2_MSG_CTX_GET_REPLY_TO(req_msg, env);
}
if(reply_to)
Modified: webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c?view=diff&rev=474280&r1=474279&r2=474280
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c Mon Nov 13 04:31:34 2006
@@ -278,7 +278,6 @@
sandesha2_seq_property_bean_set_value(out_seq_bean, env,
offer_seq_id);
- printf("int_seq_id:%s###################################33\n", int_seq_id);
sandesha2_seq_property_mgr_insert(seq_prop_mgr, env,
out_seq_bean);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org