svn commit: r712343 - /webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c

[email protected]
Newsgroups gmane.comp.apache.webservices.fx.devel
Message-ID <[email protected]>
Author: damitha
Date: Fri Nov  7 18:16:23 2008
New Revision: 712343

URL: http://svn.apache.org/viewvc?rev=712343&view=rev
Log:

In sending create seq message in dual channel msg ctx should be stored after sending the message through sandesha2 transsport sender.

Modified:
    webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c

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?rev=712343&r1=712342&r2=712343&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c Fri Nov  7 18:16:23 2008
@@ -2269,10 +2269,6 @@
     sandesha2_sender_bean_set_msg_type(create_sequence_sender_bean, env, SANDESHA2_MSG_TYPE_CREATE_SEQ);
     sandesha2_sender_mgr_insert(sender_mgr, env, create_sequence_sender_bean);
 
-    /* Store the create sequence message context in the storage */
-    sandesha2_storage_mgr_store_msg_ctx(storage_mgr, env, create_sequence_msg_store_key, create_seq_msg_ctx, AXIS2_TRUE);
-    AXIS2_FREE(env->allocator, create_sequence_msg_store_key);
-
     conf_ctx = axis2_msg_ctx_get_conf_ctx(create_seq_msg_ctx, env);
     engine = axis2_engine_create(env, conf_ctx);
 
@@ -2320,6 +2316,12 @@
     if(!is_svr_side && (listener_manager || !reply_to_addr || sandesha2_utils_is_anon_uri(env, 
                     reply_to_addr)))
     {
+        /* Store the create sequence message context in the storage */
+        sandesha2_storage_mgr_store_msg_ctx(storage_mgr, env, create_sequence_msg_store_key, 
+                create_seq_msg_ctx, AXIS2_TRUE);
+
+        AXIS2_FREE(env->allocator, create_sequence_msg_store_key);
+
         if(axis2_engine_send(engine, env, create_seq_msg_ctx))
         {
             if(!axis2_msg_ctx_get_server_side(create_seq_msg_ctx, env))
@@ -2427,6 +2429,11 @@
         {
             axis2_engine_free(engine, env);
         }
+        
+        /* Store the create sequence message context in the storage */
+        sandesha2_storage_mgr_store_msg_ctx(storage_mgr, env, create_sequence_msg_store_key, 
+                create_seq_msg_ctx, AXIS2_TRUE);
+        AXIS2_FREE(env->allocator, create_sequence_msg_store_key);
 
         /*rms_sequence_bean = sandesha2_seq_property_mgr_retrieve(seq_prop_mgr, env, 
                 internal_sequence_id, SANDESHA2_SEQUENCE_PROPERTY_RMS_SEQ_ID);*/
lmpx.com only provides a reader for public news (NNTP) servers. It is not affiliated with the servers or forums shown here and is not responsible for the content of articles, which is written by their respective authors.