ws-savan-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dami...@apache.org
Subject svn commit: r762580 - in /webservices/savan/trunk/c/src: data/axis2.xml data/module.xml handlers/savan_in_handler.c msgreceivers/savan_msg_recv.c
Date Tue, 07 Apr 2009 00:38:56 GMT
Author: damitha
Date: Tue Apr  7 00:38:56 2009
New Revision: 762580

URL: http://svn.apache.org/viewvc?rev=762580&view=rev
Log: (empty)

Modified:
    webservices/savan/trunk/c/src/data/axis2.xml
    webservices/savan/trunk/c/src/data/module.xml
    webservices/savan/trunk/c/src/handlers/savan_in_handler.c
    webservices/savan/trunk/c/src/msgreceivers/savan_msg_recv.c

Modified: webservices/savan/trunk/c/src/data/axis2.xml
URL: http://svn.apache.org/viewvc/webservices/savan/trunk/c/src/data/axis2.xml?rev=762580&r1=762579&r2=762580&view=diff
==============================================================================
--- webservices/savan/trunk/c/src/data/axis2.xml (original)
+++ webservices/savan/trunk/c/src/data/axis2.xml Tue Apr  7 00:38:56 2009
@@ -21,9 +21,6 @@
     <!-- This is the Deafult Message Receiver for the Request Response style Operations
-->
     <!--messageReceiver mep="INOUT" class="axis2_receivers"/-->
     
-    <!-- Savan message receiver -->
-    <messageReceiver mep="INOUT" class="savan_msgreceivers"/>
-
     <!-- ================================================= -->
     <!-- Transport Ins -->
     <!-- ================================================= -->

Modified: webservices/savan/trunk/c/src/data/module.xml
URL: http://svn.apache.org/viewvc/webservices/savan/trunk/c/src/data/module.xml?rev=762580&r1=762579&r2=762580&view=diff
==============================================================================
--- webservices/savan/trunk/c/src/data/module.xml (original)
+++ webservices/savan/trunk/c/src/data/module.xml Tue Apr  7 00:38:56 2009
@@ -13,18 +13,22 @@
     </inflow>
 
     <operation name="Subscribe">
+            <messageReceiver class="savan_msgreceivers" />
            <parameter name="wsamapping" >http://schemas.xmlsoap.org/ws/2004/08/eventing/Subscribe</parameter>
     </operation>
 
     <operation name="Renew">
+            <messageReceiver class="savan_msgreceivers" />
            <parameter name="wsamapping" >http://schemas.xmlsoap.org/ws/2004/08/eventing/Renew</parameter>
     </operation>
 
     <operation name="Unsubscribe">
+            <messageReceiver class="savan_msgreceivers" />
            <parameter name="wsamapping" >http://schemas.xmlsoap.org/ws/2004/08/eventing/Unsubscribe</parameter>
     </operation>
 
     <operation name="GetStatus">
+            <messageReceiver class="savan_msgreceivers" />
            <parameter name="wsamapping" >http://schemas.xmlsoap.org/ws/2004/08/eventing/GetStatus</parameter>
     </operation>
 

Modified: webservices/savan/trunk/c/src/handlers/savan_in_handler.c
URL: http://svn.apache.org/viewvc/webservices/savan/trunk/c/src/handlers/savan_in_handler.c?rev=762580&r1=762579&r2=762580&view=diff
==============================================================================
--- webservices/savan/trunk/c/src/handlers/savan_in_handler.c (original)
+++ webservices/savan/trunk/c/src/handlers/savan_in_handler.c Tue Apr  7 00:38:56 2009
@@ -69,7 +69,7 @@
     savan_message_types_t msg_type = SAVAN_MSG_TYPE_UNKNOWN;
     savan_sub_processor_t *processor = NULL;
     axis2_status_t status = AXIS2_SUCCESS;
-    axis2_bool_t to_msg_recv = AXIS2_FALSE;
+    /*axis2_bool_t to_msg_recv = AXIS2_FALSE;*/
     axis2_conf_ctx_t *conf_ctx = NULL;
     axis2_conf_t *conf = NULL;
     int type;
@@ -113,17 +113,17 @@
             {
                 status = AXIS2_FAILURE;
             }
-            else
+            /*else
             {
                 to_msg_recv = AXIS2_TRUE;
-            }
+            }*/
             break;
         }
 
         case SAVAN_MSG_TYPE_UNSUB:
         {
             status = savan_sub_processor_unsubscribe(processor, env, msg_ctx);
-            to_msg_recv = AXIS2_TRUE;
+            /*to_msg_recv = AXIS2_TRUE;*/
             break;
         }
 
@@ -131,20 +131,20 @@
         {
             if(savan_sub_processor_renew_subscription(processor, env, msg_ctx) == AXIS2_FAILURE)
             {
-                to_msg_recv = AXIS2_FALSE;
+                /*to_msg_recv = AXIS2_FALSE;*/
                 status = AXIS2_FAILURE;
             }
-            else
+            /*else
             {
                 to_msg_recv = AXIS2_TRUE;
-            }
+            }*/
             break;
         }
 
         case SAVAN_MSG_TYPE_GET_STATUS:
         {
             status = savan_sub_processor_get_status(processor, env, msg_ctx);
-            to_msg_recv = AXIS2_TRUE;
+            /*to_msg_recv = AXIS2_TRUE;*/
             break;
         }
 
@@ -157,20 +157,15 @@
         }
     }    
     
-    if (to_msg_recv)
+    /*if (to_msg_recv)
     {
         axis2_op_t *op =  axis2_msg_ctx_get_op(msg_ctx, env);
-        axis2_msg_recv_t* msg_recv = axis2_conf_get_msg_recv(conf, env, SAVAN_MESSAGE_RECEIVER);
+        axis2_msg_recv_t* msg_recv = savan_msg_recv_create(env);
         if(msg_recv)
         {
-            AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "msg_recv not null");
             axis2_op_set_msg_recv(op, env, msg_recv);
         }
-        else
-        {
-            AXIS2_LOG_DEBUG(env->log, AXIS2_LOG_SI, "msg_recv null");
-        }
-    }
+    }*/
     
     savan_sub_processor_free(processor, env);
     AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, "[savan] End:savan_in_handler_invoke");

Modified: webservices/savan/trunk/c/src/msgreceivers/savan_msg_recv.c
URL: http://svn.apache.org/viewvc/webservices/savan/trunk/c/src/msgreceivers/savan_msg_recv.c?rev=762580&r1=762579&r2=762580&view=diff
==============================================================================
--- webservices/savan/trunk/c/src/msgreceivers/savan_msg_recv.c (original)
+++ webservices/savan/trunk/c/src/msgreceivers/savan_msg_recv.c Tue Apr  7 00:38:56 2009
@@ -39,6 +39,12 @@
     axis2_msg_ctx_t *msg_ctx,
     axis2_msg_ctx_t *new_msg_ctx);
     
+static axis2_status_t
+savan_msg_recv_handle_event(
+    const axutil_env_t *env, 
+    axis2_msg_ctx_t *msg_ctx,
+    axis2_msg_ctx_t *new_msg_ctx);
+
 axis2_status_t AXIS2_CALL
 savan_msg_recv_handle_sub_request(
     const axutil_env_t *env,
@@ -99,7 +105,7 @@
     return msg_recv;
 }
 
-axis2_status_t AXIS2_CALL
+static axis2_status_t
 savan_msg_recv_handle_event(
     const axutil_env_t *env, 
     axis2_msg_ctx_t *msg_ctx,
@@ -132,7 +138,7 @@
 {
     savan_message_types_t msg_type = SAVAN_MSG_TYPE_UNKNOWN;
     axis2_status_t status = AXIS2_SUCCESS;
-    
+
     AXIS2_LOG_TRACE(env->log, AXIS2_LOG_SI, 
             "[savan] Entry:savan_msg_recv_invoke_business_logic_sync");
     



Mime
View raw message