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");
