svn commit: r583748 - in /webservices/savan/trunk/c/src: client/savan_publishing_client.c subscribers/savan_subscriber.c

[damitha]

Author: damitha
Date: Thu Oct 11 02:12:24 2007
New Revision: 583748

URL: http://svn.apache.org/viewvc?rev=583748&view=rev
Log:
Improving log messages

Modified:
    webservices/savan/trunk/c/src/client/savan_publishing_client.c
    webservices/savan/trunk/c/src/subscribers/savan_subscriber.c

Modified: webservices/savan/trunk/c/src/client/savan_publishing_client.c
URL: 
http://svn.apache.org/viewvc/webservices/savan/trunk/c/src/client/savan_publishing_client.c?rev=583748&r1=583747&r2=583748&view=diff
==============================================================================
--- webservices/savan/trunk/c/src/client/savan_publishing_client.c (original)
+++ webservices/savan/trunk/c/src/client/savan_publishing_client.c Thu Oct 11 
02:12:24 2007
@@ -22,6 +22,7 @@
 #include <axis2_conf_ctx.h>
 #include <axis2_svc.h>
 #include <axis2_svc_client.h>
+#include <axis2_endpoint_ref.h>
 #include <platforms/axutil_platform_auto_sense.h>
 
 #include <savan_publishing_client.h>
@@ -155,14 +156,24 @@
     size = axutil_array_list_size(subs_store, env);
     for(i = 0; i < size; i++)
     {
-        savan_subscriber_t * sub = NULL;
-        sub = axutil_array_list_get(subs_store, env, i);
+        savan_subscriber_t *sub = NULL;
+        sub = (savan_subscriber_t *)axutil_array_list_get(subs_store, env, i);
         if (sub)
         {
             axis2_char_t *id = savan_subscriber_get_id(sub, env);
             AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "[savan][out handler] "
                 "Publishing to %s", id);
-            savan_subscriber_publish(sub, env, payload);
+            if(!savan_subscriber_publish(sub, env, payload))
+            {
+                axis2_endpoint_ref_t *notifyto = 
+                    savan_subscriber_get_notify_to(sub, env);
+                const axis2_char_t *address = NULL;
+                if(notifyto)
+                    address = axis2_endpoint_ref_get_address(notifyto, env);
+                AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Publishing to the "\
+                    "Data Sink:%s proviced by subscriber:%s Failed. Check "\
+                    "whether the Data Sink url is correct", address, id);
+            }
         }
     }
     AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "[savan] "
@@ -170,4 +181,5 @@
     
     return AXIS2_SUCCESS;
 }
+
 

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=583748&r1=583747&r2=583748&view=diff
==============================================================================
--- webservices/savan/trunk/c/src/subscribers/savan_subscriber.c (original)
+++ webservices/savan/trunk/c/src/subscribers/savan_subscriber.c Thu Oct 11 
02:12:24 2007
@@ -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_SUCCESS;
+    axis2_status_t status = AXIS2_FAILURE;
     axis2_endpoint_ref_t *to = NULL;
     const axis2_char_t *address = NULL;
 
@@ -417,7 +417,7 @@
     if(svc_client)
     {
         axis2_svc_client_set_options(svc_client, env, options);
-        axis2_svc_client_send_robust(svc_client, env, payload);
+        status = axis2_svc_client_send_robust(svc_client, env, payload);
 
         axis2_svc_client_free(svc_client, env);
     }