Author: damitha
Date: Fri Sep 5 05:22:24 2008
New Revision: 692418
URL: http://svn.apache.org/viewvc?rev=692418&view=rev
Log:
Interoperoperablity with .net
Modified:
webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c
webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
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=692418&r1=692417&r2=692418&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c
(original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/ack_msg_processor.c Fri Sep
5 05:22:24 2008
@@ -174,6 +174,7 @@
axiom_node_t *body_node = NULL;
axiom_element_t *body_element = NULL;
axiom_children_iterator_t *children_iterator = NULL;
+ sandesha2_seq_property_bean_t *terminated_bean = NULL;
AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI,
"[sandesha2] Entry:sandesha2_ack_msg_processor_process_in_msg");
@@ -277,6 +278,49 @@
sandesha2_seq_mgr_update_last_activated_time(env,
internal_sequence_id, seq_prop_mgr);
}
+ terminated_bean = sandesha2_seq_property_mgr_retrieve(seq_prop_mgr, env,
internal_sequence_id,
+ SANDESHA2_SEQ_PROP_TERMINATE_ADDED);
+ if(terminated_bean)
+ {
+ axis2_char_t *value =
sandesha2_seq_property_bean_get_value(terminated_bean, env);
+
+ if(value && !axutil_strcmp(AXIS2_VALUE_TRUE, value))
+ {
+ AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI,
+ "[sandesha2] Terminate sequence message was added previously");
+ }
+
+ sandesha2_seq_property_bean_free(terminated_bean, env);
+
+ if(seq_prop_mgr)
+ {
+ sandesha2_seq_property_mgr_free(seq_prop_mgr, env);
+ }
+ if(create_seq_mgr)
+ {
+ sandesha2_create_seq_mgr_free(create_seq_mgr, env);
+ }
+ if(sender_mgr)
+ {
+ sandesha2_sender_mgr_free(sender_mgr, env);
+ }
+ if(next_msg_mgr)
+ {
+ sandesha2_next_msg_mgr_free(next_msg_mgr, env);
+ }
+ if(storage_mgr)
+ {
+ sandesha2_storage_mgr_free(storage_mgr, env);
+ }
+
+ if(internal_sequence_id)
+ {
+ AXIS2_FREE(env->allocator, internal_sequence_id);
+ }
+
+ return AXIS2_SUCCESS;
+ }
+
/*property = axutil_property_create_with_args(env, 0, 0, 0,
AXIS2_VALUE_TRUE);
axis2_msg_ctx_set_property(msg_ctx, env, SANDESHA2_ACK_PROCSSED,
property);*/
Modified:
webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c?rev=692418&r1=692417&r2=692418&view=diff
==============================================================================
---
webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
(original)
+++
webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
Fri Sep 5 05:22:24 2008
@@ -733,7 +733,7 @@
AXIS2_PARAM_CHECK(env->error, rm_msg_ctx, AXIS2_FAILURE);
AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI,
- "[sandesha2]Entry:sandesha2_terminate_msg_processor_process_out_msg.");
+
"[sandesha2]Entry:sandesha2_terminate_seq_msg_processor_process_out_msg.");
msg_ctx = sandesha2_msg_ctx_get_msg_ctx(rm_msg_ctx, env);
conf_ctx = axis2_msg_ctx_get_conf_ctx(msg_ctx, env);
@@ -940,7 +940,7 @@
}
AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI,
- "[sandesha2] Exit:sandesha2_terminate_msg_processor_process_out_msg");
+ "[sandesha2]
Exit:sandesha2_terminate_seq_msg_processor_process_out_msg");
return AXIS2_SUCCESS;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
