Author: manjula
Date: Thu Sep 18 23:40:17 2008
New Revision: 696938
URL: http://svn.apache.org/viewvc?rev=696938&view=rev
Log:
Adding RM11SampleService.
Added:
webservices/sandesha/trunk/c/samples/RM11SampleService/
webservices/sandesha/trunk/c/samples/RM11SampleService/Makefile.am
webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.c
webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.h
webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc_skel.c
webservices/sandesha/trunk/c/samples/RM11SampleService/services.xml
Modified:
webservices/sandesha/trunk/c/samples/Makefile.am
webservices/sandesha/trunk/c/samples/configure.ac
webservices/sandesha/trunk/c/samples/rm_echo_1_0/rm_echo.c
webservices/sandesha/trunk/c/samples/rm_echo_1_0_large_sequence/rm_echo.c
webservices/sandesha/trunk/c/samples/rm_echo_1_1/rm_echo_1_1.c
webservices/sandesha/trunk/c/samples/rm_echo_single_1_0/rm_echo_single.c
webservices/sandesha/trunk/c/samples/rm_echo_single_1_0_large_sequence/rm_echo_single.c
webservices/sandesha/trunk/c/samples/rm_echo_single_1_1/rm_echo_single_1_1.c
webservices/sandesha/trunk/c/samples/rm_mtom_1_0/rm_mtom_1_0.c
webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c
webservices/sandesha/trunk/c/samples/rm_ping_1_0_large_sequence/rm_ping_1_0.c
webservices/sandesha/trunk/c/samples/rm_ping_1_1/rm_ping_1_1.c
Modified: webservices/sandesha/trunk/c/samples/Makefile.am
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/Makefile.am?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/Makefile.am (original)
+++ webservices/sandesha/trunk/c/samples/Makefile.am Thu Sep 18 23:40:17 2008
@@ -1,4 +1,4 @@
samplesdir=$(prefix)/samples
-SUBDIRS = resources RM10SampleService rm_echo_1_0 rm_echo_1_1 rm_ping_1_0
rm_ping_1_1 rm_mtom_1_0 rm_echo_single_1_0 rm_echo_single_1_1
rm_ping_1_0_large_sequence rm_echo_single_1_0_large_sequence
rm_echo_1_0_large_sequence
+SUBDIRS = resources RM10SampleService RM11SampleService rm_echo_1_0
rm_echo_1_1 rm_ping_1_0 rm_ping_1_1 rm_mtom_1_0 rm_echo_single_1_0
rm_echo_single_1_1 rm_ping_1_0_large_sequence rm_echo_single_1_0_large_sequence
rm_echo_1_0_large_sequence
samples_DATA= Makefile.am Makefile.in
Added: webservices/sandesha/trunk/c/samples/RM11SampleService/Makefile.am
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/RM11SampleService/Makefile.am?rev=696938&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/samples/RM11SampleService/Makefile.am (added)
+++ webservices/sandesha/trunk/c/samples/RM11SampleService/Makefile.am Thu Sep
18 23:40:17 2008
@@ -0,0 +1,10 @@
+prglibdir=$(prefix)/services/RM11SampleService
+samplesdir=$(prefix)/samples/server/rm/RM11SampleService
+prglib_LTLIBRARIES = libRM11SampleService.la
+samples_DATA=rm_sample_svc.c rm_sample_svc_skel.c rm_sample_svc.h services.xml
Makefile.am Makefile.in
+prglib_DATA= services.xml
+EXTRA_DIST = services.xml rm_sample_svc.h
+noinst_HEADERS = rm_sample_svc.h
+libRM11SampleService_la_SOURCES = rm_sample_svc.c rm_sample_svc_skel.c
+INCLUDES = @AXIS2INC@
+
Added: webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.c?rev=696938&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.c
(added)
+++ webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.c Thu
Sep 18 23:40:17 2008
@@ -0,0 +1,395 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "rm_sample_svc.h"
+#include <axiom_xml_writer.h>
+#include <stdio.h>
+#include <axutil_qname.h>
+#include <axiom_output.h>
+#include <axiom_element.h>
+
+axiom_node_t *build_response1(
+ const axutil_env_t * env,
+ axis2_char_t * text);
+
+axiom_node_t *build_response2(
+ const axutil_env_t *env,
+ axiom_data_handler_t *data_handler);
+
+axiom_node_t *
+build_echo_om(
+ const axutil_env_t *env,
+ const axis2_char_t *text);
+
+axiom_node_t *
+rm_sample_svc_echo (
+ const axutil_env_t *env,
+ axiom_node_t *node)
+{
+ axiom_node_t *text_parent_node = NULL;
+ axiom_node_t *text_node = NULL;
+ axiom_node_t *ret_node = NULL;
+
+ /* Expected request format is :-
+ * <ns1:echoString xmlns:ns1="http://ws.apache.org/axis2/c/samples";>
+ * <text>echo5</text>
+ * </ns1:echoString>
+ */
+ if (!node) /* 'echoString' node */
+ {
+ AXIS2_ERROR_SET(env->error, AXIS2_ERROR_SVC_SKEL_INPUT_OM_NODE_NULL,
AXIS2_FAILURE);
+ return NULL;
+ }
+
+ text_parent_node = axiom_node_get_first_element(node, env);
+ if (!text_parent_node) /* 'text' node */
+ {
+ AXIS2_ERROR_SET(env->error,
+ AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST, AXIS2_FAILURE);
+
+ return NULL;
+ }
+
+ text_node = axiom_node_get_first_child(text_parent_node, env);
+ if (!text_node) /* actual text to echo */
+ {
+ AXIS2_ERROR_SET(env->error,
+ AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST, AXIS2_FAILURE);
+ return NULL;
+ }
+
+ if (axiom_node_get_node_type(text_node, env) == AXIOM_TEXT)
+ {
+ axiom_text_t *text = (axiom_text_t
*)axiom_node_get_data_element(text_node, env);
+ if( text && axiom_text_get_value(text , env))
+ {
+ const axis2_char_t *text_str = axiom_text_get_value(text, env);
+ ret_node = build_echo_om(env, text_str);
+ }
+ }
+ else
+ {
+ AXIS2_ERROR_SET(env->error,
AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST, AXIS2_FAILURE);
+ return NULL;
+ }
+
+ return ret_node;
+}
+
+/* Builds the response content */
+axiom_node_t *
+build_echo_om(
+ const axutil_env_t *env,
+ const axis2_char_t *text)
+{
+ axiom_node_t *echo_om_node = NULL;
+ axiom_element_t* echo_om_ele = NULL;
+ axiom_node_t* text_om_node = NULL;
+ axiom_element_t * text_om_ele = NULL;
+ axiom_namespace_t *ns1 = NULL;
+
+ ns1 = axiom_namespace_create (env, "http://tempuri.org/";, "ns1");
+
+ echo_om_ele = axiom_element_create(env, NULL, "echoStringResponse", ns1,
&echo_om_node);
+ text_om_ele = axiom_element_create(env, echo_om_node, "EchoStringReturn",
ns1, &text_om_node);
+ axiom_element_set_text(text_om_ele, env, text, text_om_node);
+
+
+ return echo_om_node;
+}
+
+void
+rm_sample_svc_ping (
+ const axutil_env_t *env,
+ axiom_node_t *node)
+{
+ axiom_node_t *text_parent_node = NULL;
+ axiom_element_t *text_parent_element = NULL;
+ axiom_node_t *text_node = NULL;
+ axiom_element_t *element = NULL;
+ axis2_char_t *ns = "http://tempuri.org/";;
+ axutil_qname_t *qname = NULL;
+
+ AXIS2_ENV_CHECK(env, NULL);
+
+ /* Expected request format is :-
+ * <ns1:echoString xmlns:ns1="http://ws.apache.org/axis2/c/samples";>
+ * <text>echo5</text>
+ * </ns1:echoString>
+ */
+ if (!node) /* 'echoString' node */
+ {
+ AXIS2_ERROR_SET(env->error, AXIS2_ERROR_SVC_SKEL_INPUT_OM_NODE_NULL,
AXIS2_FAILURE);
+ return;
+ }
+ else
+ {
+ axiom_xml_writer_t *writer = NULL;
+ axiom_output_t *om_output = NULL;
+ axis2_char_t *buffer = NULL;
+
+ writer = axiom_xml_writer_create_for_memory(env, NULL, AXIS2_TRUE, 0,
+ AXIS2_XML_PARSER_TYPE_BUFFER);
+ om_output = axiom_output_create (env, writer);
+ if (!om_output)
+ {
+ AXIS2_LOG_ERROR(env->log, AXIS2_LOG_SI, "Could not create
om_output");
+ axiom_xml_writer_free(writer, env);
+ writer = NULL;
+ return;
+ }
+ axiom_node_serialize (node, env, om_output);
+ buffer = axiom_xml_writer_get_xml(writer, env);
+ axiom_output_free(om_output, env);
+ }
+
+ element = axiom_node_get_data_element(node, env);
+ qname = axutil_qname_create(env, "Text", ns, NULL);
+ text_parent_element = axiom_element_get_first_child_with_qname(element,
env,
+ qname, node, &text_parent_node);
+ axutil_qname_free(qname, env);
+ if (!text_parent_node) /* 'text' node */
+ {
+ AXIS2_ERROR_SET(env->error,
AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST, AXIS2_FAILURE);
+ return;
+ }
+
+ text_node = axiom_node_get_first_child(text_parent_node, env);
+ if (!text_node) /* actual text to echo */
+ {
+ AXIS2_ERROR_SET(env->error,
AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST, AXIS2_FAILURE);
+ return;
+ }
+
+ if (axiom_node_get_node_type(text_node, env) == AXIOM_TEXT)
+ {
+ /*axiom_text_t *text = (axiom_text_t
*)axiom_node_get_data_element(text_node, env);
+ if( text && axiom_text_get_value(text , env))
+ {
+ axis2_char_t *text_str = axiom_text_get_value(text, env);
+ }*/
+ }
+ else
+ {
+ AXIS2_ERROR_SET(env->error,
AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST, AXIS2_FAILURE);
+ return;
+ }
+
+ return;
+}
+
+axiom_node_t *
+rm_sample_svc_mtom(
+ const axutil_env_t *env,
+ axiom_node_t *node,
+ axis2_msg_ctx_t *msg_ctx)
+{
+ axiom_node_t *file_name_node = NULL;
+ axiom_node_t *file_text_node = NULL;
+ axiom_node_t *ret_node = NULL;
+
+ AXIS2_ENV_CHECK(env, NULL);
+
+ /* Expected request format is :-
+ * <ns1:mtomSample xmlns:ns1="http://ws.apache.org/axis2/c/samples";>
+ <ns1:fileName>test.jpg</ns1:fileName>
+ <ns1:image>
+ <xop:Include xmlns:xop="http://www.w3.org/2004/08/xop/include";
href="cid:[email protected]"></xop:Include>
+ </ns1:image>
+ </ns1:mtomSample>
+ */
+ if (!node) /* 'mtomSample' node */
+ {
+ AXIS2_ERROR_SET(env->error, AXIS2_ERROR_SVC_SKEL_INPUT_OM_NODE_NULL,
+ AXIS2_FAILURE);
+ printf("Echo client ERROR: input parameter NULL\n");
+ return NULL;
+ }
+
+ file_name_node = axiom_node_get_first_child(node, env);
+ if (!file_name_node) /* 'text' node */
+ {
+ AXIS2_ERROR_SET(env->error,
+ AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST,
+ AXIS2_FAILURE);
+ printf("Echo client ERROR: invalid XML in request\n");
+ return NULL;
+ }
+
+ file_text_node = axiom_node_get_first_child(file_name_node, env);
+ if (!file_text_node) /* actual text to mtom */
+ {
+ AXIS2_ERROR_SET(env->error,
+ AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST,
+ AXIS2_FAILURE);
+ printf("Echo client ERROR: invalid XML in request\n");
+ return NULL;
+ }
+
+ if (axiom_node_get_node_type(file_text_node, env) == AXIOM_TEXT)
+ {
+ axiom_text_t *text =
+ (axiom_text_t *) axiom_node_get_data_element(file_text_node, env);
+ if (text && axiom_text_get_value(text, env))
+ {
+ axiom_node_t *image_node = NULL;
+ axis2_char_t *text_str =
+ (axis2_char_t *) axiom_text_get_value(text, env);
+ printf("File Name %s \n", text_str);
+
+ image_node = axiom_node_get_next_sibling(file_name_node, env);
+ if (image_node)
+ {
+ /* axiom_node_t *inc_node = NULL;
+ inc_node = axiom_node_get_first_child(image_node, env);
+ if (inc_node)
+ { */
+ axiom_node_t *binary_node = NULL;
+ binary_node = axiom_node_get_first_child(image_node, env);
+ if (binary_node)
+ {
+ axiom_data_handler_t *data_handler = NULL;
+ axiom_text_t *bin_text = (axiom_text_t *)
+ axiom_node_get_data_element(binary_node, env);
+ data_handler = axiom_text_get_data_handler(bin_text, env);
+ if (data_handler)
+ {
+ axiom_data_handler_t *data_handler_res = NULL;
+ axis2_byte_t *input_buff = NULL;
+ axis2_byte_t *buff = NULL;
+ int buff_len = 0;
+
+
+ axiom_data_handler_set_file_name(data_handler, env,
+ text_str);
+ axiom_data_handler_write_to(data_handler, env);
+
+ input_buff =
axiom_data_handler_get_input_stream(data_handler, env);
+ buff_len =
axiom_data_handler_get_input_stream_len(data_handler, env);
+
+ data_handler_res = axiom_data_handler_create(env,
NULL, NULL);
+
+ buff = AXIS2_MALLOC(env->allocator,
sizeof(axis2_byte_t)*buff_len);
+ memcpy(buff, input_buff, buff_len);
+
+ axiom_data_handler_set_binary_data(data_handler_res,
env, buff, buff_len);
+
+ axis2_msg_ctx_set_doing_mtom (msg_ctx, env,
AXIS2_TRUE);
+ ret_node = build_response2(env, data_handler_res);
+ }
+ else if (axiom_node_get_node_type(binary_node, env) ==
AXIOM_TEXT) /* attachment has come by value, as non-optimized binary */
+ {
+ int plain_binary_len = 0;
+ int ret_len = 0;
+ axiom_text_t *bin_text = (axiom_text_t *)
+ axiom_node_get_data_element(binary_node, env);
+ axis2_byte_t *plain_binary = NULL;
+ axiom_data_handler_t *data_handler = NULL;
+
+ axis2_char_t *base64text =
+ (axis2_char_t *) axiom_text_get_value(bin_text,
+ env);
+ printf("base64text = %s\n", base64text);
+ plain_binary_len =
axutil_base64_decode_len(base64text);
+ plain_binary = AXIS2_MALLOC(env->
+ allocator,
+ sizeof(unsigned char) *
+ plain_binary_len);
+ ret_len =
+ axutil_base64_decode_binary((unsigned char *)
+ plain_binary,
+ base64text);
+ data_handler =
+ axiom_data_handler_create(env, text_str, NULL);
+ axiom_data_handler_set_binary_data(data_handler, env,
+ plain_binary,
+ ret_len);
+ axiom_data_handler_write_to(data_handler, env);
+ ret_node = build_response1(env, base64text);
+ }
+ else /* attachement missing */
+ {
+ AXIS2_ERROR_SET(env->error,
+ AXIS2_ERROR_ATTACHMENT_MISSING,
+ AXIS2_FAILURE);
+ printf("Echo client ERROR: attachment is missing.\n");
+ return NULL;
+ }
+ /* } */
+ }
+ }
+
+ }
+ }
+ else
+ {
+ AXIS2_ERROR_SET(env->error,
+ AXIS2_ERROR_SVC_SKEL_INVALID_XML_FORMAT_IN_REQUEST,
+ AXIS2_FAILURE);
+ printf("Echo client ERROR: invalid XML in request\n");
+ return NULL;
+ }
+ return ret_node;
+}
+
+axiom_node_t *
+build_response1(
+ const axutil_env_t * env,
+ axis2_char_t * text)
+{
+ axiom_node_t *mtom_om_node = NULL;
+ axiom_element_t *mtom_om_ele = NULL;
+ axiom_node_t *om_node = NULL;
+ axiom_element_t *om_ele = NULL;
+
+
+ axiom_namespace_t *ns1 = NULL;
+
+ ns1 =
+ axiom_namespace_create(env, "http://ws.apache.org/axis2/c/samples";,
+ "ns1");
+
+ mtom_om_ele =
+ axiom_element_create(env, NULL, "response", ns1, &mtom_om_node);
+
+ om_ele = axiom_element_create(env, mtom_om_node, "string", NULL,
&om_node);
+
+ axiom_element_set_text(mtom_om_ele, env, text, om_node);
+
+
+ return mtom_om_node;
+}
+
+
+axiom_node_t *build_response2(
+ const axutil_env_t *env,
+ axiom_data_handler_t *data_handler)
+{
+ axiom_node_t *mtom_om_node = NULL;
+ axiom_element_t *mtom_om_ele = NULL;
+ axiom_node_t *text_node = NULL;
+ axiom_namespace_t *ns1 = NULL;
+
+ ns1 =
+ axiom_namespace_create(env, "http://ws.apache.org/axis2/c/samples";,
+ "ns1");
+ mtom_om_ele =
+ axiom_element_create(env, NULL, "response", ns1, &mtom_om_node);
+
+ axiom_text_create_with_data_handler(env, mtom_om_node, data_handler,
+ &text_node);
+
+ return mtom_om_node;
+}
Added: webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.h
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.h?rev=696938&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.h
(added)
+++ webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc.h Thu
Sep 18 23:40:17 2008
@@ -0,0 +1,43 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef CALC_H
+#define CALC_H
+
+
+#include <axis2_svc_skeleton.h>
+#include <axutil_log_default.h>
+#include <axutil_error_default.h>
+#include <axiom_text.h>
+#include <axiom_node.h>
+#include <axiom_element.h>
+
+axiom_node_t *
+rm_sample_svc_echo(
+ const axutil_env_t *env,
+ axiom_node_t *node);
+
+void
+rm_sample_svc_ping (
+ const axutil_env_t *env,
+ axiom_node_t *node);
+
+axiom_node_t *
+rm_sample_svc_mtom(
+ const axutil_env_t *env,
+ axiom_node_t *node,
+ axis2_msg_ctx_t *msg_ctx);
+
+#endif /* CALC_H*/
Added:
webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc_skel.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc_skel.c?rev=696938&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc_skel.c
(added)
+++ webservices/sandesha/trunk/c/samples/RM11SampleService/rm_sample_svc_skel.c
Thu Sep 18 23:40:17 2008
@@ -0,0 +1,193 @@
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <axis2_svc_skeleton.h>
+#include "rm_sample_svc.h"
+#include <axutil_array_list.h>
+#include <axis2_op.h>
+#include <axiom_element.h>
+
+int AXIS2_CALL
+rm_sample_svc_free(
+ axis2_svc_skeleton_t *svc_skeleton,
+ const axutil_env_t *env);
+
+axis2_status_t AXIS2_CALL
+rm_sample_svc_free_void_arg(
+ void *svc_skeleton,
+ const axutil_env_t *env);
+
+/*
+ * This method invokes the right service method
+ */
+axiom_node_t* AXIS2_CALL
+rm_sample_svc_invoke(
+ axis2_svc_skeleton_t *svc_skeleton,
+ const axutil_env_t *env,
+ axiom_node_t *node,
+ axis2_msg_ctx_t *msg_ctx);
+
+
+int AXIS2_CALL
+rm_sample_svc_init(
+ axis2_svc_skeleton_t *svc_skeleton,
+ const axutil_env_t *env);
+
+axiom_node_t* AXIS2_CALL
+rm_sample_svc_on_fault(
+ axis2_svc_skeleton_t *svc_skeli,
+ const axutil_env_t *env, axiom_node_t *node);
+
+static const axis2_svc_skeleton_ops_t rm_sample_svc_ops_var = {
+ rm_sample_svc_init,
+ rm_sample_svc_invoke,
+ rm_sample_svc_on_fault,
+ rm_sample_svc_free
+};
+
+/*Create function */
+axis2_svc_skeleton_t *
+rm_sample_svc_create(
+ const axutil_env_t *env)
+{
+ axis2_svc_skeleton_t *svc_skeleton = NULL;
+ /* Allocate memory for the structs */
+ svc_skeleton = AXIS2_MALLOC(env->allocator, sizeof(axis2_svc_skeleton_t));
+
+ svc_skeleton->ops = AXIS2_MALLOC(env->allocator,
sizeof(axis2_svc_skeleton_ops_t));
+ svc_skeleton->ops = &rm_sample_svc_ops_var;
+ svc_skeleton->func_array = NULL;
+
+ return svc_skeleton;
+}
+
+/* Initialize the service */
+int AXIS2_CALL
+rm_sample_svc_init(
+ axis2_svc_skeleton_t *svc_skeleton,
+ const axutil_env_t *env)
+{
+ /* Any initialization stuff of echo service should go here */
+ return AXIS2_SUCCESS;
+}
+
+/*
+ * This method invokes the right service method
+ */
+axiom_node_t* AXIS2_CALL
+rm_sample_svc_invoke(
+ axis2_svc_skeleton_t *svc_skeleton,
+ const axutil_env_t *env,
+ axiom_node_t *node,
+ axis2_msg_ctx_t *msg_ctx)
+{
+ axis2_op_t *op = NULL;
+ axutil_qname_t *op_qname = NULL;
+ axis2_char_t *op_name = NULL;
+
+ op = axis2_msg_ctx_get_op(msg_ctx, env);
+ if(op)
+ {
+ op_qname = (axutil_qname_t *)axis2_op_get_qname(op, env);
+ if(op_qname)
+ {
+ op_name = axutil_qname_get_localpart(op_qname, env);
+ }
+
+ if(op_name)
+ {
+ if (!axutil_strcmp(op_name, "echoString"))
+ {
+ return rm_sample_svc_echo(env, node);
+ }
+ if (!axutil_strcmp(op_name, "ping"))
+ {
+ rm_sample_svc_ping(env, node);
+ return NULL;
+ }
+ if (!axutil_strcmp(op_name, "mtomSample"))
+ {
+ return rm_sample_svc_mtom(env, node, msg_ctx);
+ }
+ }
+ }
+
+ return NULL;
+}
+
+/* On fault, handle the fault */
+axiom_node_t* AXIS2_CALL
+rm_sample_svc_on_fault(
+ axis2_svc_skeleton_t *svc_skeli,
+ const axutil_env_t *env,
+ axiom_node_t *node)
+{
+ /* Here we are just setting a simple error message inside an element
+ * called 'EchoServiceError'
+ */
+ axiom_node_t *error_node = NULL;
+ axiom_node_t* text_node = NULL;
+ axiom_element_t *error_ele = NULL;
+ error_ele = axiom_element_create(env, node, "EchoServiceError", NULL,
&error_node);
+ axiom_element_set_text(error_ele, env, "Echo service failed ", text_node);
+ return error_node;
+}
+
+/* Free the resources used */
+int AXIS2_CALL
+rm_sample_svc_free(
+ axis2_svc_skeleton_t *svc_skeleton,
+ const axutil_env_t *env)
+{
+ /* Free the service skeleton */
+ if(svc_skeleton)
+ {
+ AXIS2_FREE(env->allocator, svc_skeleton);
+ svc_skeleton = NULL;
+ }
+
+ return AXIS2_SUCCESS;
+}
+
+
+/**
+ * Following block distinguish the exposed part of the dll.
+ */
+AXIS2_EXPORT int
+axis2_get_instance(axis2_svc_skeleton_t **inst,
+ const axutil_env_t *env)
+{
+ *inst = rm_sample_svc_create(env);
+ if(!(*inst))
+ {
+ return AXIS2_FAILURE;
+ }
+
+ return AXIS2_SUCCESS;
+}
+
+AXIS2_EXPORT int
+axis2_remove_instance(
+ axis2_svc_skeleton_t *inst,
+ const axutil_env_t *env)
+{
+ axis2_status_t status = AXIS2_FAILURE;
+ if (inst)
+ {
+ status = AXIS2_SVC_SKELETON_FREE(inst, env);
+ }
+ return status;
+}
+
Added: webservices/sandesha/trunk/c/samples/RM11SampleService/services.xml
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/RM11SampleService/services.xml?rev=696938&view=auto
==============================================================================
--- webservices/sandesha/trunk/c/samples/RM11SampleService/services.xml (added)
+++ webservices/sandesha/trunk/c/samples/RM11SampleService/services.xml Thu Sep
18 23:40:17 2008
@@ -0,0 +1,46 @@
+<service name="RM11SampleService">
+ <module ref="sandesha2"/>
+ <module ref="addressing"/>
+ <parameter name="ServiceClass"
locked="xsd:false">RM11SampleService</parameter>
+
+ <description>
+ This is a Relaible Messaging test service to be used in interop
testing with java
+ </description>
+
+ <operation name="echoString">
+ <parameter name="wsamapping"
>http://tempuri.org/echoString</parameter>
+ </operation>
+ <operation name="ping" mep="http://www.w3.org/2004/08/wsdl/in-only";>
+ <parameter name="wsamapping" >http://tempuri.org/ping</parameter>
+ </operation>
+ <operation name="mtomSample">
+ <parameter name="wsamapping"
>http://ws.apache.org/axis2/c/samples/mtom</parameter>
+ </operation>
+
+ <wsp:Policy wsu:Id="RmPolicy"
xmlns:wsp="http://schemas.xmlsoap.org/ws/2004/09/policy";
xmlns:wsrmp="http://docs.oasis-open.org/ws-rx/wsrmp/200702";
xmlns:sanc="http://ws.apache.org/sandesha2/c/policy";
xmlns:wsu="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd";>
+ <wsp:ExactlyOne>
+ <wsp:All>
+ <wsrmp:RMAssertion>
+ <wsp:Policy>
+ <wsrmp:DeliveryAssurance>
+ <wsp:Policy>
+ <wsrmp:ExactlyOnce/>
+ <!--wsrmp:InOrder/-->
+ </wsp:Policy>
+ </wsrmp:DeliveryAssurance>
+ </wsp:Policy>
+ <sanc:InactivityTimeout>600000</sanc:InactivityTimeout>
+
<sanc:AcknowledgementInterval>200</sanc:AcknowledgementInterval>
+
<sanc:BaseRetransmissionInterval>8</sanc:BaseRetransmissionInterval>
+ <sanc:StorageManager>persistent</sanc:StorageManager>
+ <sanc:MessageTypesToDrop>none</sanc:MessageTypesToDrop>
+ <sanc:MaxRetransCount>10</sanc:MaxRetransCount>
+ <sanc:SenderSleepTime>1</sanc:SenderSleepTime><!--In
seconds-->
+ <sanc:InvokerSleepTime>1</sanc:InvokerSleepTime>
+ <sanc:PollingWaitTime>4</sanc:PollingWaitTime>
+ <sanc:TerminateDelay>4</sanc:TerminateDelay>
+ </wsrmp:RMAssertion>
+ </wsp:All>
+ </wsp:ExactlyOne>
+ </wsp:Policy>
+</service>
Modified: webservices/sandesha/trunk/c/samples/configure.ac
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/configure.ac?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/configure.ac (original)
+++ webservices/sandesha/trunk/c/samples/configure.ac Thu Sep 18 23:40:17 2008
@@ -70,6 +70,7 @@
AC_CONFIG_FILES([Makefile \
RM10SampleService/Makefile \
+ RM11SampleService/Makefile \
rm_echo_1_0/Makefile \
rm_echo_1_0_large_sequence/Makefile \
rm_echo_1_1/Makefile \
Modified: webservices/sandesha/trunk/c/samples/rm_echo_1_0/rm_echo.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_echo_1_0/rm_echo.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_echo_1_0/rm_echo.c (original)
+++ webservices/sandesha/trunk/c/samples/rm_echo_1_0/rm_echo.c Thu Sep 18
23:40:17 2008
@@ -80,7 +80,7 @@
AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM10SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
@@ -319,7 +319,7 @@
fprintf(stdout, " [-a ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The" \
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService \n");
+ " default is http://127.0.0.1:9090/axis2/services/RM10SampleService
\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified:
webservices/sandesha/trunk/c/samples/rm_echo_1_0_large_sequence/rm_echo.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_echo_1_0_large_sequence/rm_echo.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_echo_1_0_large_sequence/rm_echo.c
(original)
+++ webservices/sandesha/trunk/c/samples/rm_echo_1_0_large_sequence/rm_echo.c
Thu Sep 18 23:40:17 2008
@@ -80,7 +80,7 @@
AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM10SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
@@ -316,7 +316,7 @@
fprintf(stdout, " [-a ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The" \
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService \n");
+ " default is http://127.0.0.1:9090/axis2/services/RM10SampleService
\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified: webservices/sandesha/trunk/c/samples/rm_echo_1_1/rm_echo_1_1.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_echo_1_1/rm_echo_1_1.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_echo_1_1/rm_echo_1_1.c (original)
+++ webservices/sandesha/trunk/c/samples/rm_echo_1_1/rm_echo_1_1.c Thu Sep 18
23:40:17 2008
@@ -80,7 +80,7 @@
env = axutil_env_create_all("rm_echo_1_1.log", AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM11SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:o:")) != -1)
{
@@ -126,7 +126,7 @@
/* Seperate listner needs addressing, hence addressing stuff in options */
/*axis2_options_set_action(options, env,
- "http://127.0.0.1:8080/axis2/services/RMSampleService/anonOutInOp";);*/
+
"http://127.0.0.1:8080/axis2/services/RM11SampleService/anonOutInOp";);*/
axis2_options_set_action(options, env, "urn:wsrm:EchoString");
reply_to = axis2_endpoint_ref_create(env,
"http://localhost:6060/axis2/services/__ANONYMOUS_SERVICE__/"\
@@ -325,7 +325,7 @@
fprintf(stdout, "\t-o OFFER \t seq offer value.. Type 1 for sequence
offer" \
"feature. The default behaviour is no offer(0). \n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The" \
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService \n");
+ " default is http://127.0.0.1:9090/axis2/services/RM11SampleService
\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified:
webservices/sandesha/trunk/c/samples/rm_echo_single_1_0/rm_echo_single.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_echo_single_1_0/rm_echo_single.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_echo_single_1_0/rm_echo_single.c
(original)
+++ webservices/sandesha/trunk/c/samples/rm_echo_single_1_0/rm_echo_single.c
Thu Sep 18 23:40:17 2008
@@ -60,7 +60,7 @@
AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM10SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
@@ -256,7 +256,7 @@
fprintf(stdout, " [-a ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The" \
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService \n");
+ " default is http://127.0.0.1:9090/axis2/services/RM10SampleService
\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified:
webservices/sandesha/trunk/c/samples/rm_echo_single_1_0_large_sequence/rm_echo_single.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_echo_single_1_0_large_sequence/rm_echo_single.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
---
webservices/sandesha/trunk/c/samples/rm_echo_single_1_0_large_sequence/rm_echo_single.c
(original)
+++
webservices/sandesha/trunk/c/samples/rm_echo_single_1_0_large_sequence/rm_echo_single.c
Thu Sep 18 23:40:17 2008
@@ -62,7 +62,7 @@
AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM10SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
@@ -248,7 +248,7 @@
fprintf(stdout, " [-a ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The" \
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService \n");
+ " default is http://127.0.0.1:9090/axis2/services/RM10SampleService
\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified:
webservices/sandesha/trunk/c/samples/rm_echo_single_1_1/rm_echo_single_1_1.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_echo_single_1_1/rm_echo_single_1_1.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
---
webservices/sandesha/trunk/c/samples/rm_echo_single_1_1/rm_echo_single_1_1.c
(original)
+++
webservices/sandesha/trunk/c/samples/rm_echo_single_1_1/rm_echo_single_1_1.c
Thu Sep 18 23:40:17 2008
@@ -62,8 +62,8 @@
/* Set end point reference of echo service */
- /*address = "http://127.0.0.1:9090/axis2/services/RMSampleService";*/
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ /*address = "http://127.0.0.1:9090/axis2/services/RM11SampleService";*/
+ address = "http://127.0.0.1:9090/axis2/services/RM11SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
@@ -104,7 +104,7 @@
/* Seperate listner needs addressing, hence addressing stuff in options */
axis2_options_set_action(options, env,
- "http://127.0.0.1:8080/axis2/services/RMSampleService/anonOutInOp";);
+ "http://127.0.0.1:8080/axis2/services/RM11SampleService/anonOutInOp";);
reply_to = axis2_endpoint_ref_create(env, AXIS2_WSA_ANONYMOUS_URL);
axis2_options_set_reply_to(options, env, reply_to);
@@ -283,7 +283,7 @@
fprintf(stdout, " [-a ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The" \
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService \n");
+ " default is http://127.0.0.1:9090/axis2/services/RM11SampleService
\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified: webservices/sandesha/trunk/c/samples/rm_mtom_1_0/rm_mtom_1_0.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_mtom_1_0/rm_mtom_1_0.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_mtom_1_0/rm_mtom_1_0.c (original)
+++ webservices/sandesha/trunk/c/samples/rm_mtom_1_0/rm_mtom_1_0.c Thu Sep 18
23:40:17 2008
@@ -67,7 +67,7 @@
AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM10SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
switch (c)
@@ -269,7 +269,7 @@
fprintf(stdout, " [-o ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-o ADDRESS \t endpoint address.. The"
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService
../\n");
+ " default is http://127.0.0.1:9090/axis2/services/RM10SampleService
../\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified: webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c (original)
+++ webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c Thu Sep 18
23:40:17 2008
@@ -56,7 +56,7 @@
env = axutil_env_create_all("rm_ping.log", AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM10SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
@@ -242,7 +242,7 @@
fprintf(stdout, " [-a ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The"
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService
../\n");
+ " default is
http://127.0.0.1:9090/axis2/services/RM10SampleService ../\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified:
webservices/sandesha/trunk/c/samples/rm_ping_1_0_large_sequence/rm_ping_1_0.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_ping_1_0_large_sequence/rm_ping_1_0.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
---
webservices/sandesha/trunk/c/samples/rm_ping_1_0_large_sequence/rm_ping_1_0.c
(original)
+++
webservices/sandesha/trunk/c/samples/rm_ping_1_0_large_sequence/rm_ping_1_0.c
Thu Sep 18 23:40:17 2008
@@ -22,6 +22,8 @@
#include <sandesha2_client_constants.h>
#include <sandesha2_constants.h>
#include <ctype.h>
+#include <neethi_policy.h>
+#include <neethi_util.h>
#define SANDESHA2_SLEEP 4
@@ -49,12 +51,13 @@
int c;
int i = 0;
axis2_char_t *seq_key = NULL;
+ neethi_policy_t *policy = NULL;
/* Set up the environment */
env = axutil_env_create_all("rm_ping.log", AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM10SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:")) != -1)
{
@@ -108,6 +111,22 @@
AXIS2_ERROR_GET_MESSAGE(env->error));
}
+ /*Create the policy, from file*/
+ policy = neethi_util_create_policy_from_file(env,
"policy/rm10-policy.xml");
+ if(!policy)
+ {
+ printf("\nPolicy creation failed from the file");
+ return 0;
+ }
+
+ status = axis2_svc_client_set_policy(svc_client, env, policy);
+
+ if(status == AXIS2_FAILURE)
+ {
+ printf("Policy setting failed\n");
+ }
+
+
/* Set service client options */
axis2_svc_client_set_options(svc_client, env, options);
@@ -210,7 +229,7 @@
fprintf(stdout, " [-a ADDRESS]");
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The"
- " default is http://127.0.0.1:9090/axis2/services/RMSampleService
../\n");
+ " default is
http://127.0.0.1:9090/axis2/services/RM10SampleService ../\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
Modified: webservices/sandesha/trunk/c/samples/rm_ping_1_1/rm_ping_1_1.c
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/samples/rm_ping_1_1/rm_ping_1_1.c?rev=696938&r1=696937&r2=696938&view=diff
==============================================================================
--- webservices/sandesha/trunk/c/samples/rm_ping_1_1/rm_ping_1_1.c (original)
+++ webservices/sandesha/trunk/c/samples/rm_ping_1_1/rm_ping_1_1.c Thu Sep 18
23:40:17 2008
@@ -57,7 +57,7 @@
env = axutil_env_create_all("rm_ping.log", AXIS2_LOG_LEVEL_TRACE);
/* Set end point reference of echo service */
- address = "http://127.0.0.1:9090/axis2/services/RMSampleService";;
+ address = "http://127.0.0.1:9090/axis2/services/RM11SampleService";;
while ((c = AXIS2_GETOPT(argc, argv, ":a:k:")) != -1)
{
@@ -228,7 +228,7 @@
fprintf(stdout, " Options :\n");
fprintf(stdout, "\t-k PROVIDE SEQUENCE KEY \t provide the sequence key as
string \n");
fprintf(stdout, "\t-a ADDRESS \t endpoint address.. The"
- " default is http://127.0.0.1:5555/axis2/services/RMSampleService
../\n");
+ " default is
http://127.0.0.1:5555/axis2/services/RM11SampleService ../\n");
fprintf(stdout, " Help :\n\t-h \t display this help screen.\n\n");
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
