svn commit: r662186 - in /webservices/savan/trunk/c: configure.ac src/subscribers/savan_subscriber.c

[damitha]

Author: damitha
Date: Sun Jun  1 02:16:57 2008
New Revision: 662186

URL: http://svn.apache.org/viewvc?rev=662186&view=rev
Log:
Applying patch in AXIS2C-1164

Modified:
    webservices/savan/trunk/c/configure.ac
    webservices/savan/trunk/c/src/subscribers/savan_subscriber.c

Modified: webservices/savan/trunk/c/configure.ac
URL: 
http://svn.apache.org/viewvc/webservices/savan/trunk/c/configure.ac?rev=662186&r1=662185&r2=662186&view=diff
==============================================================================
--- webservices/savan/trunk/c/configure.ac (original)
+++ webservices/savan/trunk/c/configure.ac Sun Jun  1 02:16:57 2008
@@ -45,7 +45,7 @@
 abs_top_builddir=`pwd`
 AC_SUBST(abs_top_builddir)
 
-AC_MSG_CHECKING(path to use Axis2C . This is a compulsory to build Sandesha2C)
+AC_MSG_CHECKING(path to use Axis2C . This is a compulsory to build Savan/C)
 AC_ARG_WITH(axis2,
 [  --with-axis2[=PATH]      use axis2c.],
 [ case "$withval" in

Modified: webservices/savan/trunk/c/src/subscribers/savan_subscriber.c
URL: 
http://svn.apache.org/viewvc/webservices/savan/trunk/c/src/subscribers/savan_subscriber.c?rev=662186&r1=662185&r2=662186&view=diff
==============================================================================
--- webservices/savan/trunk/c/src/subscribers/savan_subscriber.c (original)
+++ webservices/savan/trunk/c/src/subscribers/savan_subscriber.c Sun Jun  1 
02:16:57 2008
@@ -380,7 +380,7 @@
     axis2_svc_client_t *svc_client = NULL;
     axis2_char_t *path = NULL;
     axis2_options_t *options = NULL;
-    axis2_status_t status = AXIS2_FAILURE;
+    axis2_status_t status = AXIS2_SUCCESS;
     axis2_endpoint_ref_t *to = NULL;
     const axis2_char_t *address = NULL;
 
@@ -415,20 +415,26 @@
 
        /* Apply the filter, and check whether it evaluates to success */
 
-#ifdef SAVAN_FILTERING
+    #ifdef SAVAN_FILTERING
        if (savan_util_apply_filter(subscriber, env, payload) == AXIS2_FAILURE)
        {
                return AXIS2_SUCCESS;
        }
-#endif
+    #endif
        
     /* Set service client options */
     axis2_svc_client_set_options(svc_client, env, options);
     status = axis2_svc_client_send_robust(svc_client, env, payload);
-    axis2_svc_client_free(svc_client, env);
 
-    AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, 
-        "[savan] End:savan_subscriber_publish");
+    axiom_node_detach(payload, env); /*insert this to prevent payload 
corruption in subsequent 
+                                       "publish" calls with some payload.*/
+    if(svc_client)
+    {
+        axis2_svc_client_free(svc_client, env);
+    }
+
+    AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "[savan] 
End:savan_subscriber_publish");
+
     return status;
 }