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:1.dd5183d4-d58a-1da1-2578-001125b4c063-1oDqGaOF3Lkdnm+yROfE0A@public.gmane.org"></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");
}
lmpx.com only provides a reader for public news (NNTP) servers. It is not
affiliated with the servers or forums shown here and is not responsible for
the content of articles, which is written by their respective authors.