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 sa...@apache.org on 2007/02/19 04:33:02 UTC

svn commit: r509077 - in /webservices/sandesha/trunk/c/src: msgprocessors/ storage/permanent/ util/

Author: samisa
Date: Sun Feb 18 19:33:01 2007
New Revision: 509077

URL: http://svn.apache.org/viewvc?view=rev&rev=509077
Log:
Fixed the breaks due to changes to Axi2/C

Modified:
    webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c
    webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c
    webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c
    webservices/sandesha/trunk/c/src/msgprocessors/create_seq_res_msg_processor.c
    webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c
    webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
    webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c
    webservices/sandesha/trunk/c/src/util/ack_mgr.c
    webservices/sandesha/trunk/c/src/util/sandesha2_utils.c
    webservices/sandesha/trunk/c/src/util/seq_mgr.c
    webservices/sandesha/trunk/c/src/util/terminate_mgr.c

Modified: webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c Sun Feb 18 19:33:01 2007
@@ -251,7 +251,7 @@
     if(0 == AXIS2_STRCMP(anon_uri, acks_to_str))
     {
         axis2_engine_t *engine = NULL;
-        axis2_ctx_t *ctx = NULL;
+        axis2_op_ctx_t *op_ctx = NULL;
         
         if(!AXIS2_MSG_CTX_GET_OP(msg_ctx, env))
         {
@@ -265,11 +265,8 @@
             AXIS2_MSG_CTX_SET_OP(msg_ctx, env, operation);
             AXIS2_MSG_CTX_SET_OP_CTX(msg_ctx, env, op_ctx);            
         }
-        ctx = AXIS2_OP_CTX_GET_BASE(AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env), env);
-        
-        property = axis2_property_create_with_args(env, 0, 0, 0, "TRUE");
-        AXIS2_CTX_SET_PROPERTY(ctx, env, AXIS2_RESPONSE_WRITTEN, property, 
-            AXIS2_FALSE);
+        op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
+        axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
         
         property = axis2_property_create_with_args(env, 0, 0, 0, 
             SANDESHA2_VALUE_TRUE);

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=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/app_msg_processor.c Sun Feb 18 19:33:01 2007
@@ -183,7 +183,6 @@
     axis2_msg_ctx_t *msg_ctx = NULL;
     axis2_char_t *processed = NULL;
     axis2_op_ctx_t *op_ctx = NULL;
-    axis2_ctx_t *ctx = NULL;
     axis2_conf_ctx_t *conf_ctx = NULL;
     axis2_property_t *property = NULL;
     sandesha2_storage_mgr_t *storage_mgr = NULL;
@@ -235,17 +234,8 @@
         return AXIS2_SUCCESS;
     }
     
-    op_ctx = axis2_msg_ctx_get_op_ctx(msg_ctx, env);
-    if (op_ctx)
-    {
-        ctx = AXIS2_OP_CTX_GET_BASE(op_ctx, env);
-        if (ctx)
-        {
-            property = axis2_property_create_with_args(env, 0, 0, 0, "FALSE");
-            AXIS2_CTX_SET_PROPERTY(ctx, env, AXIS2_RESPONSE_WRITTEN,
-                property, AXIS2_FALSE);
-        }
-    }
+    op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
+    axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
     conf_ctx = axis2_msg_ctx_get_conf_ctx(msg_ctx, env);
     storage_mgr = sandesha2_utils_get_storage_mgr(env, conf_ctx, 
         AXIS2_CONF_CTX_GET_CONF(conf_ctx, env));
@@ -515,7 +505,7 @@
     if(axis2_msg_ctx_get_server_side(msg_ctx, env))
     {
         sandesha2_last_msg_t *last_msg = sandesha2_seq_get_last_msg(seq, env);
-        axis2_char_t *msg_id = axis2_msg_ctx_get_msg_id(msg_ctx, env);
+        axis2_char_t *msg_id = (axis2_char_t *)axis2_msg_ctx_get_msg_id(msg_ctx, env);
         if(last_msg)
         {
             sandesha2_seq_property_bean_t *seq_prop_bean = NULL;
@@ -641,7 +631,7 @@
         last_req_id = sandesha2_utils_get_seq_property(env, incoming_seq_id,
             SANDESHA2_SEQ_PROP_LAST_IN_MESSAGE_ID, storage_mgr);
         relates_to = axis2_msg_ctx_get_relates_to(msg_ctx, env);
-        relates_to_value = axis2_relates_to_get_value(relates_to, env);
+        relates_to_value = (axis2_char_t *)axis2_relates_to_get_value(relates_to, env);
         if(relates_to && last_req_id && 0 == axis2_strcmp(last_req_id, 
             relates_to_value))
         {
@@ -920,17 +910,9 @@
             written = axis2_property_get_value(property, env);
         if(!written || 0 != axis2_strcmp(written, SANDESHA2_VALUE_TRUE))
         {
-            axis2_ctx_t *ctx = NULL;
             if (op_ctx)
             {
-                ctx = AXIS2_OP_CTX_GET_BASE(op_ctx, env);
-                if (ctx)
-                {
-                    property = axis2_property_create_with_args(env, 0, 0, 0, 
-                        "TRUE");
-                    AXIS2_CTX_SET_PROPERTY(ctx, env, 
-                        AXIS2_RESPONSE_WRITTEN, property, AXIS2_FALSE);
-                }
+                axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
             }
         }        
     }

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=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/create_seq_msg_processor.c Sun Feb 18 19:33:01 2007
@@ -167,7 +167,7 @@
     axis2_char_t *addr_ns_uri = NULL;
     axis2_char_t *anon_uri = NULL;
     axis2_endpoint_ref_t *to_epr = NULL;
-    axis2_ctx_t *ctx = NULL;
+    axis2_op_ctx_t *op_ctx = NULL;
      
     AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
     AXIS2_PARAM_CHECK(env->error, rm_msg_ctx, AXIS2_FAILURE);
@@ -311,7 +311,8 @@
                     new_seq_id, SANDESHA2_SEQ_PROP_ACKS_TO_EPR, 
                     (axis2_char_t*)AXIS2_ENDPOINT_REF_GET_ADDRESS(acks_to, env));
     sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, acks_to_bean);
-    axis2_msg_ctx_set_response_written(out_msg_ctx, env, AXIS2_TRUE);
+    op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
+    axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
     sandesha2_seq_mgr_update_last_activated_time(env, new_seq_id, 
                     storage_mgr);
     engine = axis2_engine_create(env, conf_ctx);
@@ -330,14 +331,12 @@
                     storage_mgr);
     anon_uri = sandesha2_spec_specific_consts_get_anon_uri(env, addr_ns_uri);
     
-    ctx = AXIS2_OP_CTX_GET_BASE(AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env), env);
+    op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
     if(0 == AXIS2_STRCMP(anon_uri, AXIS2_ENDPOINT_REF_GET_ADDRESS(to_epr, 
                     env)))
-        property = axis2_property_create_with_args(env, 0, 0, 0, "TRUE");
+        axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
     else
-        property = axis2_property_create_with_args(env, 0, 0, 0, "FALSE");
-    AXIS2_CTX_SET_PROPERTY(ctx, env, AXIS2_RESPONSE_WRITTEN, property, 
-                    AXIS2_FALSE);
+        axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_FALSE);
     
     sandesha2_msg_ctx_set_paused(rm_msg_ctx, env, AXIS2_TRUE);
     AXIS2_LOG_INFO(env->log, 

Modified: webservices/sandesha/trunk/c/src/msgprocessors/create_seq_res_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/create_seq_res_msg_processor.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/create_seq_res_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/create_seq_res_msg_processor.c Sun Feb 18 19:33:01 2007
@@ -178,8 +178,7 @@
     sandesha2_sender_bean_t *target_bean = NULL;
     axis2_array_list_t *found_list = NULL;
     int i = 0, size = 0;
-    axis2_ctx_t *ctx = NULL;
-    axis2_property_t *property = NULL;
+    axis2_op_ctx_t *op_ctx = NULL;
     axis2_bool_t polling_mode = AXIS2_FALSE;
     
     AXIS2_ENV_CHECK(env, AXIS2_FAILURE);
@@ -448,10 +447,8 @@
         sandesha2_storage_mgr_update_msg_ctx(storage_mgr, env, key, app_msg_ctx);
     }
     sandesha2_seq_mgr_update_last_activated_time(env, int_seq_id, storage_mgr);
-    ctx = AXIS2_OP_CTX_GET_BASE(AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env), env);
-    property = axis2_property_create_with_args(env, 0, 0, 0, "TRUE");
-    AXIS2_CTX_SET_PROPERTY(ctx, env, AXIS2_RESPONSE_WRITTEN, property, 
-                        AXIS2_FALSE);
+    op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
+    axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
     sandesha2_msg_ctx_set_paused(rm_msg_ctx, env, AXIS2_TRUE);
     AXIS2_LOG_INFO(env->log, 
             "[sandesha2] Exit: sandesha2_create_seq_res_msg_processor_process_in_msg");

Modified: webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c Sun Feb 18 19:33:01 2007
@@ -279,16 +279,9 @@
     set_transport_properties(env, return_msg_ctx, rm_msg_ctx);
     /* Setting that the response gets written. This will be used by transports.*/
     if(msg_ctx)
-        op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
-    if(op_ctx)
     {
-        axis2_ctx_t *ctx = AXIS2_OP_CTX_GET_BASE(op_ctx, env);
-        if (ctx)
-        {
-            property = axis2_property_create_with_args(env, 0, 0, 0, "TRUE");
-            AXIS2_CTX_SET_PROPERTY(ctx, env, AXIS2_RESPONSE_WRITTEN,
-                                        property, AXIS2_FALSE);
-        }
+        op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
+        axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
     }
     /*
      *running the make_connection through a sender_worker.

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?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c Sun Feb 18 19:33:01 2007
@@ -360,7 +360,7 @@
     axis2_char_t *addr_ns_uri = NULL;
     axis2_char_t *anon_uri = NULL;
     axis2_endpoint_ref_t *to_epr = NULL;
-    axis2_ctx_t *ctx = NULL;
+    axis2_op_ctx_t *op_ctx = NULL;
     axis2_transport_out_desc_t *orig_trans_out = NULL;
     axis2_transport_out_desc_t *trans_out = NULL;
     sandesha2_sender_bean_t *term_res_bean = NULL;
@@ -438,19 +438,16 @@
     anon_uri = sandesha2_spec_specific_consts_get_anon_uri(env, addr_ns_uri);
     to_epr = AXIS2_MSG_CTX_GET_TO(msg_ctx, env);
     
-    ctx = AXIS2_OP_CTX_GET_BASE(AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env), env);
-    
+    op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(msg_ctx, env);
     if(0 == AXIS2_STRCMP(anon_uri, AXIS2_ENDPOINT_REF_GET_ADDRESS(to_epr, env)))
     {
-        property = axis2_property_create_with_args(env, 0, 0, 0, "TRUE");
+        axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
     }
     else
     {
-        property = axis2_property_create_with_args(env, 0, 0, 0, "FALSE");
+        axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_FALSE);
     }
         
-    AXIS2_CTX_SET_PROPERTY(ctx, env, AXIS2_RESPONSE_WRITTEN, property,
-        AXIS2_FALSE);
     return AXIS2_SUCCESS;
 }
     
@@ -561,10 +558,9 @@
 
     if(transport_to)
     {
-        property = axis2_property_create_with_args(env, 0, 0, 0, transport_to);
-        axis2_msg_ctx_set_property(msg_ctx, env, 
-                        AXIS2_TRANSPORT_URL, property, AXIS2_FALSE);
+        axis2_msg_ctx_set_transport_url(msg_ctx, env, transport_to);
     }
+
     sandesha2_msg_ctx_add_soap_envelope(rm_msg_ctx, env);
     
     /*key = axis2_uuid_gen(env);

Modified: webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c Sun Feb 18 19:33:01 2007
@@ -621,6 +621,8 @@
     axis2_char_t *prop_str = NULL;
     axis2_op_ctx_t *op_ctx = NULL;
     sandesha2_msg_store_bean_t *bean = NULL;
+    axis2_char_t *transport_to = NULL;
+        
     envelope = AXIS2_MSG_CTX_GET_SOAP_ENVELOPE(msg_ctx, env);
     if (!envelope)
     {
@@ -707,14 +709,13 @@
         address = (axis2_char_t *) AXIS2_ENDPOINT_REF_GET_ADDRESS(reply_to, env);
         sandesha2_msg_store_bean_set_reply_to(bean, env, address);
     }
-    property = AXIS2_MSG_CTX_GET_PROPERTY(msg_ctx, env, AXIS2_TRANSPORT_URL,
-        AXIS2_FALSE);
-    if(property)
+    
+    transport_to = axis2_msg_ctx_get_transport_url(msg_ctx, env);
+    if(transport_to)
     {
-        axis2_char_t *transport_to = NULL;
-        transport_to = (axis2_char_t *) AXIS2_PROPERTY_GET_VALUE(property, env);
         sandesha2_msg_store_bean_set_transport_to(bean, env, transport_to);
     }
+
     options = (axis2_options_t *) axis2_msg_ctx_get_options(msg_ctx, env);
     action  = (axis2_char_t *) AXIS2_OPTIONS_GET_ACTION(options, env);
     sandesha2_msg_store_bean_set_action(bean, env, action);
@@ -781,7 +782,6 @@
     axis2_transport_out_desc_t *transport_out_desc = NULL;
     axis2_endpoint_ref_t *endpoint_ref = NULL;
     axis2_op_t *op = NULL;
-    axis2_property_t *property = NULL;
     axis2_options_t *options = NULL;
     axiom_xml_reader_t *reader = NULL;
     int soap_version = -1;
@@ -958,9 +958,7 @@
         env);
     if(transport_to_str)
     {
-        property = axis2_property_create_with_args(env, 0, 0, 0, transport_to_str);
-        AXIS2_MSG_CTX_SET_PROPERTY(msg_ctx, env, AXIS2_TRANSPORT_URL, property,
-        AXIS2_FALSE);
+        axis2_msg_ctx_set_transport_url(msg_ctx, env, transport_to_str);
     }
     to_url_str = sandesha2_msg_store_bean_get_to_url(msg_store_bean, env);
     if(to_url_str)

Modified: webservices/sandesha/trunk/c/src/util/ack_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/ack_mgr.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/util/ack_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/ack_mgr.c Sun Feb 18 19:33:01 2007
@@ -143,7 +143,6 @@
     anon_uri = sandesha2_spec_specific_consts_get_anon_uri(env, addr_ns_uri);
     if(0 == AXIS2_STRCMP(acks_to_str, anon_uri))
     {
-        axis2_ctx_t *ref_ctx = NULL;
         axis2_op_ctx_t *op_ctx = NULL;
 
         op_ctx = AXIS2_MSG_CTX_GET_OP_CTX(ref_msg, env);
@@ -155,11 +154,7 @@
             AXIS2_MSG_CTX_SET_OP(ref_msg, env, op);
             AXIS2_MSG_CTX_SET_OP_CTX(ref_msg, env, op_ctx);            
         }
-        ref_ctx = AXIS2_OP_CTX_GET_BASE(op_ctx, env);
-        property = axis2_property_create_with_args(env, AXIS2_SCOPE_REQUEST, 
-            AXIS2_FALSE, 0, "TRUE");
-        AXIS2_CTX_SET_PROPERTY(ref_ctx, env, AXIS2_RESPONSE_WRITTEN,
-            property, AXIS2_FALSE);
+        axis2_op_ctx_set_response_written(op_ctx, env, AXIS2_TRUE);
         
         property = axis2_property_create_with_args(env, AXIS2_SCOPE_REQUEST, 
             AXIS2_FALSE, 0, SANDESHA2_VALUE_TRUE);

Modified: webservices/sandesha/trunk/c/src/util/sandesha2_utils.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/sandesha2_utils.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/util/sandesha2_utils.c (original)
+++ webservices/sandesha/trunk/c/src/util/sandesha2_utils.c Sun Feb 18 19:33:01 2007
@@ -621,6 +621,7 @@
     axis2_char_t *paused_phase_name = NULL;
     axis2_svc_grp_t *svc_grp = NULL;
     axis2_stream_t *out_stream = NULL;
+    axis2_char_t *transport_to = NULL;
     
     AXIS2_ENV_CHECK(env, NULL);
     AXIS2_PARAM_CHECK(env->error, ref_rm_msg, NULL);
@@ -723,15 +724,10 @@
                         AXIS2_MSG_CTX_GET_SOAP_ENVELOPE(ref_msg, env)));
     AXIS2_MSG_CTX_SET_SOAP_ENVELOPE(new_msg, env, soap_env);
     
-    property = AXIS2_MSG_CTX_GET_PROPERTY(ref_msg, env, AXIS2_TRANSPORT_URL,
-                        AXIS2_FALSE);
-    if(property)
-    {
-        axis2_char_t *value = AXIS2_PROPERTY_GET_VALUE(property, env);
-        property = axis2_property_create_with_args(env, AXIS2_SCOPE_REQUEST, 
-            AXIS2_FALSE, 0, value);
-        AXIS2_MSG_CTX_SET_PROPERTY(new_msg, env, AXIS2_TRANSPORT_URL, property,
-                        AXIS2_FALSE);
+    transport_to = axis2_msg_ctx_get_transport_url(ref_msg, env);
+    if(transport_to)
+    {
+        axis2_msg_ctx_set_transport_url(new_msg, env, transport_to);
     }
     property = AXIS2_MSG_CTX_GET_PROPERTY(ref_msg, env, AXIS2_WSA_VERSION,
                         AXIS2_FALSE);

Modified: webservices/sandesha/trunk/c/src/util/seq_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/seq_mgr.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/util/seq_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/seq_mgr.c Sun Feb 18 19:33:01 2007
@@ -471,10 +471,7 @@
         sandesha2_seq_property_mgr_insert(seq_prop_mgr, env, reply_to_bean);
         
     
-    property = AXIS2_MSG_CTX_GET_PROPERTY(first_app_msg, env, AXIS2_TRANSPORT_URL,
-                        AXIS2_FALSE);
-    if(property)
-        transport_to = AXIS2_PROPERTY_GET_VALUE(property, env);
+    transport_to = axis2_msg_ctx_get_transport_url(first_app_msg, env);
     
     if(transport_to)
     {

Modified: webservices/sandesha/trunk/c/src/util/terminate_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/terminate_mgr.c?view=diff&rev=509077&r1=509076&r2=509077
==============================================================================
--- webservices/sandesha/trunk/c/src/util/terminate_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/terminate_mgr.c Sun Feb 18 19:33:01 2007
@@ -671,7 +671,7 @@
         axis2_char_t *value = sandesha2_seq_property_bean_get_value(
             transport_to_bean, env);
         property = axis2_property_create_with_args(env, 0, 0, 0, value);
-        sandesha2_msg_ctx_set_property(terminate_rm_msg, env, 
+        sandesha2_msg_ctx_set_property(terminate_rm_msg, env,
             AXIS2_TRANSPORT_URL, property);
     }
     
@@ -680,14 +680,9 @@
        sandesha2_utils_is_single_channel(env, rm_ver, to_addr))
     {
         axis2_msg_ctx_t *msg_ctx1 = sandesha2_msg_ctx_get_msg_ctx(terminate_rm_msg, env);
-        axis2_ctx_t *ctx = NULL;
-        axis2_property_t *property = NULL;
-        axis2_msg_ctx_set_response_written(msg_ctx1, env, AXIS2_TRUE);
+        axis2_op_ctx_set_response_written(axis2_msg_ctx_get_op_ctx(msg_ctx1, env), env, AXIS2_TRUE);
         axis2_msg_ctx_set_paused(msg_ctx, env, AXIS2_TRUE);
-        ctx = axis2_op_ctx_get_base(axis2_msg_ctx_get_op_ctx(msg_ctx, env), env);
-        property = axis2_property_create_with_args(env, 0, 0, 0, "TRUE");    
-        axis2_ctx_set_property(ctx, env, AXIS2_RESPONSE_WRITTEN, property,
-            AXIS2_FALSE);
+        axis2_op_ctx_set_response_written(axis2_msg_ctx_get_op_ctx(msg_ctx, env), env, AXIS2_TRUE);
         engine = axis2_engine_create(env, conf_ctx);
         AXIS2_ENGINE_SEND(engine, env, msg_ctx1);
         /* Clean sending side data */



---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org