You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by sa...@apache.org on 2007/02/20 11:18:00 UTC
svn commit: r509493 - in /webservices/sandesha/trunk/c: config/ include/
samples/rm_ping_1_0/ src/client/ src/core/ src/msgprocessors/
src/storage/permanent/ src/util/ src/workers/
Author: samisa
Date: Tue Feb 20 02:17:59 2007
New Revision: 509493
URL: http://svn.apache.org/viewvc?view=rev&rev=509493
Log:
Fixed RM in accordance with the current axis2c changess
Modified:
webservices/sandesha/trunk/c/config/module.xml
webservices/sandesha/trunk/c/config/sandesha2_schema.sh
webservices/sandesha/trunk/c/include/sandesha2_msg_ctx.h
webservices/sandesha/trunk/c/samples/rm_ping_1_0/rm_ping_1_0.c
webservices/sandesha/trunk/c/src/client/client.c
webservices/sandesha/trunk/c/src/core/Makefile.am
webservices/sandesha/trunk/c/src/core/sandesha2_msg_ctx.c
webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c
webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c
webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c
webservices/sandesha/trunk/c/src/util/ack_mgr.c
webservices/sandesha/trunk/c/src/util/sandesha2_utils.c
webservices/sandesha/trunk/c/src/util/terminate_mgr.c
webservices/sandesha/trunk/c/src/workers/sender.c
webservices/sandesha/trunk/c/src/workers/sender_worker.c
Modified: webservices/sandesha/trunk/c/config/module.xml
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/config/module.xml?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/config/module.xml (original)
+++ webservices/sandesha/trunk/c/config/module.xml Tue Feb 20 02:17:59 2007
@@ -68,7 +68,7 @@
</operation>
<!-- Database connection parameters -->
- <parameter name="sandesha2_db" locked="false">/axis2c/deploy</parameter>
+ <parameter name="sandesha2_db" locked="false">/tmp</parameter>
<!-- General parameters -->
<parameter name="ExponentialBackoff" locked="false">AXIS2_TRUE</parameter>
<parameter name="RetransmissionInterval" locked="false">20000</parameter>
Modified: webservices/sandesha/trunk/c/config/sandesha2_schema.sh
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/config/sandesha2_schema.sh?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/config/sandesha2_schema.sh (original)
+++ webservices/sandesha/trunk/c/config/sandesha2_schema.sh Tue Feb 20 02:17:59 2007
@@ -1,50 +1,50 @@
#!/bin/bash
-sqlite sandesha2_svr_db "drop table create_seq;"
-sqlite sandesha2_svr_db "drop table invoker;"
-sqlite sandesha2_svr_db "drop table sender"
-sqlite sandesha2_svr_db "drop table next_msg"
-sqlite sandesha2_svr_db "drop table seq_property"
-sqlite sandesha2_svr_db "drop table msg"
-sqlite sandesha2_svr_db "create table create_seq(create_seq_msg_id varchar(100) primary key,
+sqlite3 sandesha2_svr_db "drop table create_seq;"
+sqlite3 sandesha2_svr_db "drop table invoker;"
+sqlite3 sandesha2_svr_db "drop table sender"
+sqlite3 sandesha2_svr_db "drop table next_msg"
+sqlite3 sandesha2_svr_db "drop table seq_property"
+sqlite3 sandesha2_svr_db "drop table msg"
+sqlite3 sandesha2_svr_db "create table create_seq(create_seq_msg_id varchar(100) primary key,
internal_seq_id varchar(200), seq_id varchar(200), create_seq_msg_store_key varchar(100),
ref_msg_store_key varchar(100))"
-sqlite sandesha2_svr_db "create table invoker(msg_ctx_ref_key varchar(100) primary key,
+sqlite3 sandesha2_svr_db "create table invoker(msg_ctx_ref_key varchar(100) primary key,
msg_no long, seq_id varchar(200), is_invoked boolean)"
-sqlite sandesha2_svr_db "create table sender(msg_id varchar(100) primary key,
+sqlite3 sandesha2_svr_db "create table sender(msg_id varchar(100) primary key,
msg_ctx_ref_key varchar(100), internal_seq_id varchar(200), sent_count int,
msg_no long, send boolean, resend boolean, time_to_send long, msg_type int,
seq_id varchar(200), wsrm_anon_uri varchar(100), to_address varchar(100))"
-sqlite sandesha2_svr_db "create table next_msg(seq_id varchar(200) primary key,
+sqlite3 sandesha2_svr_db "create table next_msg(seq_id varchar(200) primary key,
ref_msg_key varchar(100), polling_mode boolean, msg_no long)"
-sqlite sandesha2_svr_db "create table seq_property(id varchar(200) primary key,
+sqlite3 sandesha2_svr_db "create table seq_property(id varchar(200) primary key,
seq_id varchar(200), name varchar(200), value varchar(200))"
-sqlite sandesha2_svr_db "create table msg(stored_key varchar(200) primary key,
+sqlite3 sandesha2_svr_db "create table msg(stored_key varchar(200) primary key,
msg_id varchar(200), soap_env_str text, soap_version int, transport_out varchar(100),
op varchar(100), svc varchar(100), svc_grp varchar(100), op_mep varchar(100), to_url varchar(200),
reply_to varchar(200), transport_to varchar(200), execution_chain_str varchar(200), flow int,
msg_recv_str varchar(200), svr_side boolean, in_msg_store_key varchar(200), prop_str varchar(8192),
action varchar(200))"
-sqlite sandesha2_client_db "drop table create_seq;"
-sqlite sandesha2_client_db "drop table invoker;"
-sqlite sandesha2_client_db "drop table sender"
-sqlite sandesha2_client_db "drop table next_msg"
-sqlite sandesha2_client_db "drop table seq_property"
-sqlite sandesha2_client_db "drop table msg"
-sqlite sandesha2_client_db "create table create_seq(create_seq_msg_id varchar(100) primary key,
+sqlite3 sandesha2_client_db "drop table create_seq;"
+sqlite3 sandesha2_client_db "drop table invoker;"
+sqlite3 sandesha2_client_db "drop table sender"
+sqlite3 sandesha2_client_db "drop table next_msg"
+sqlite3 sandesha2_client_db "drop table seq_property"
+sqlite3 sandesha2_client_db "drop table msg"
+sqlite3 sandesha2_client_db "create table create_seq(create_seq_msg_id varchar(100) primary key,
internal_seq_id varchar(200), seq_id varchar(200), create_seq_msg_store_key varchar(100),
ref_msg_store_key varchar(100))"
-sqlite sandesha2_client_db "create table invoker(msg_ctx_ref_key varchar(100) primary key,
+sqlite3 sandesha2_client_db "create table invoker(msg_ctx_ref_key varchar(100) primary key,
msg_no long, seq_id varchar(200), is_invoked boolean)"
-sqlite sandesha2_client_db "create table sender(msg_id varchar(100) primary key,
+sqlite3 sandesha2_client_db "create table sender(msg_id varchar(100) primary key,
msg_ctx_ref_key varchar(100), internal_seq_id varchar(200), sent_count int,
msg_no long, send boolean, resend boolean, time_to_send long, msg_type int,
seq_id varchar(200), wsrm_anon_uri varchar(100), to_address varchar(100))"
-sqlite sandesha2_client_db "create table next_msg(seq_id varchar(200) primary key,
+sqlite3 sandesha2_client_db "create table next_msg(seq_id varchar(200) primary key,
ref_msg_key varchar(100), polling_mode boolean, msg_no long)"
-sqlite sandesha2_client_db "create table seq_property(id varchar(200) primary key,
+sqlite3 sandesha2_client_db "create table seq_property(id varchar(200) primary key,
seq_id varchar(200), name varchar(200), value varchar(200))"
-sqlite sandesha2_client_db "create table msg(stored_key varchar(200) primary key,
+sqlite3 sandesha2_client_db "create table msg(stored_key varchar(200) primary key,
msg_id varchar(200), soap_env_str text, soap_version int, transport_out varchar(100),
op varchar(100), svc varchar(100), svc_grp varchar(100), op_mep varchar(100), to_url varchar(200),
reply_to varchar(200), transport_to varchar(200), execution_chain_str varchar(200), flow int,
Modified: webservices/sandesha/trunk/c/include/sandesha2_msg_ctx.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_msg_ctx.h?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_msg_ctx.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_msg_ctx.h Tue Feb 20 02:17:59 2007
@@ -255,6 +255,22 @@
const axis2_env_t *env,
axis2_stream_t *stream);
+AXIS2_EXTERN struct axis2_http_out_transport_info *AXIS2_CALL
+sandesha2_msg_ctx_get_http_out_transport_info(
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ const axis2_env_t *env);
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_msg_ctx_set_http_out_transport_info(
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ const axis2_env_t *env,
+ struct axis2_http_out_transport_info *http_out_transport_info);
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_msg_ctx_reset_http_out_transport_info(
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ const axis2_env_t *env);
+
/** @} */
#ifdef __cplusplus
}
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?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- 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 Tue Feb 20 02:17:59 2007
@@ -53,7 +53,7 @@
/* Set up the environment */
/*env = axis2_env_create_all("rm_ping.log", AXIS2_LOG_LEVEL_TRACE);*/
- env = axis2_env_create_all("rm_ping.log", AXIS2_LOG_LEVEL_CRITICAL);
+ env = axis2_env_create_all("rm_ping.log", AXIS2_LOG_LEVEL_DEBUG);
/* Set end point reference of echo service */
/*address = "http://127.0.0.1:8888/axis2/services/RMSampleService";*/
Modified: webservices/sandesha/trunk/c/src/client/client.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/client/client.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/client/client.c (original)
+++ webservices/sandesha/trunk/c/src/client/client.c Tue Feb 20 02:17:59 2007
@@ -675,6 +675,8 @@
conf_ctx = AXIS2_SVC_CTX_GET_CONF_CTX(svc_ctx, env);
terminate_envelope = sandesha2_client_configure_terminate_seq(env, options,
conf_ctx);
+ if (!terminate_envelope)
+ return AXIS2_FAILURE;
body = AXIOM_SOAP_ENVELOPE_GET_BODY(terminate_envelope, env);
node = AXIOM_SOAP_BODY_GET_BASE_NODE(body, env);
element = AXIOM_NODE_GET_DATA_ELEMENT(node, env);
Modified: webservices/sandesha/trunk/c/src/core/Makefile.am
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/core/Makefile.am?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/core/Makefile.am (original)
+++ webservices/sandesha/trunk/c/src/core/Makefile.am Tue Feb 20 02:17:59 2007
@@ -19,6 +19,6 @@
../workers/libsandesha2_workers.la\
../wsrm/libsandesha2_wsrm.la \
../polling/libsandesha2_polling.la \
- ./libsqlite3.a
+ -lsqlite3
Modified: webservices/sandesha/trunk/c/src/core/sandesha2_msg_ctx.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/core/sandesha2_msg_ctx.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/core/sandesha2_msg_ctx.c (original)
+++ webservices/sandesha/trunk/c/src/core/sandesha2_msg_ctx.c Tue Feb 20 02:17:59 2007
@@ -547,3 +547,35 @@
stream);
}
+AXIS2_EXTERN struct axis2_http_out_transport_info *AXIS2_CALL
+sandesha2_msg_ctx_get_http_out_transport_info(
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ const axis2_env_t *env)
+{
+ if(!rm_msg_ctx->msg_ctx)
+ return NULL;
+ return axis2_msg_ctx_get_http_out_transport_info(rm_msg_ctx->msg_ctx, env);
+}
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_msg_ctx_set_http_out_transport_info(
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ const axis2_env_t *env,
+ struct axis2_http_out_transport_info *http_out_transport_info)
+{
+ if(!rm_msg_ctx->msg_ctx)
+ return AXIS2_FAILURE;
+ return axis2_msg_ctx_set_http_out_transport_info(rm_msg_ctx->msg_ctx,
+ env, http_out_transport_info);
+}
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_msg_ctx_reset_http_out_transport_info(
+ sandesha2_msg_ctx_t *rm_msg_ctx,
+ const axis2_env_t *env)
+{
+ if(!rm_msg_ctx->msg_ctx)
+ return AXIS2_FAILURE;
+ return axis2_msg_ctx_reset_http_out_transport_info(rm_msg_ctx->msg_ctx, env);
+}
+
Modified: webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/ack_req_msg_processor.c Tue Feb 20 02:17:59 2007
@@ -340,7 +340,7 @@
old_ack_bean = AXIS2_ARRAY_LIST_GET(found_list, env, i);
time_to_send = sandesha2_sender_bean_get_time_to_send(
old_ack_bean, env);
- char *msg_id = sandesha2_sender_bean_get_msg_id(old_ack_bean, env);
+ /*char *msg_id = sandesha2_sender_bean_get_msg_id(old_ack_bean, env);*/
sandesha2_sender_mgr_remove(retrans_mgr, env,
sandesha2_sender_bean_get_msg_id((sandesha2_rm_bean_t *)
old_ack_bean, env));
Modified: webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/make_connection_msg_processor.c Tue Feb 20 02:17:59 2007
@@ -45,6 +45,7 @@
#include <axis2_op_ctx.h>
#include <axis2_transport_out_desc.h>
#include <axis2_http_transport.h>
+#include <axis2_http_out_transport_info.h>
#include <axis2_rand.h>
#include <sandesha2_msg_retrans_adjuster.h>
#include <sandesha2_terminate_mgr.h>
@@ -458,10 +459,10 @@
axis2_msg_ctx_t *return_msg_ctx,
sandesha2_msg_ctx_t *make_conn_msg_ctx)
{
- axis2_property_t *property = NULL;
axis2_stream_t *out_stream = NULL;
if(make_conn_msg_ctx && return_msg_ctx)
{
+ axis2_http_out_transport_info_t *out_info = NULL;
/*property = sandesha2_msg_ctx_get_property(make_conn_msg_ctx, env,
AXIS2_TRANSPORT_OUT);
axis2_property_set_own_value(property, env, AXIS2_FALSE);
@@ -470,12 +471,9 @@
out_stream = sandesha2_msg_ctx_get_transport_out_stream(make_conn_msg_ctx,
env);
axis2_msg_ctx_set_transport_out_stream(return_msg_ctx, env, out_stream);
- property = sandesha2_msg_ctx_get_property(make_conn_msg_ctx, env,
- AXIS2_HTTP_OUT_TRANSPORT_INFO);
- axis2_property_set_own_value(property, env, AXIS2_FALSE);
- axis2_msg_ctx_set_property(return_msg_ctx, env,
- AXIS2_HTTP_OUT_TRANSPORT_INFO, axis2_property_clone(property, env),
- AXIS2_FALSE);
+ out_info = (axis2_http_out_transport_info_t *)
+ sandesha2_msg_ctx_get_http_out_transport_info(make_conn_msg_ctx, env);
+ axis2_msg_ctx_set_http_out_transport_info(return_msg_ctx, env, out_info);
}
}
Modified: webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c (original)
+++ webservices/sandesha/trunk/c/src/msgprocessors/terminate_seq_msg_processor.c Tue Feb 20 02:17:59 2007
@@ -409,7 +409,7 @@
property = axis2_property_create_with_args(env, 0, 0, 0, key);
axis2_msg_ctx_set_property(out_msg_ctx, env, SANDESHA2_MESSAGE_STORE_KEY,
property, AXIS2_FALSE);
- char *action = axis2_msg_ctx_get_wsa_action(out_msg_ctx, env);
+ /*char *action = axis2_msg_ctx_get_wsa_action(out_msg_ctx, env);*/
sandesha2_storage_mgr_store_msg_ctx(storage_mgr, env, key, out_msg_ctx);
/* TODO: refine the terminate delay */
Modified: webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/storage/permanent/permanent_storage_mgr.c Tue Feb 20 02:17:59 2007
@@ -621,7 +621,6 @@
axis2_char_t *prop_str = NULL;
axis2_op_ctx_t *op_ctx = NULL;
sandesha2_msg_store_bean_t *bean = NULL;
- axis2_char_t *transport_to = NULL;
envelope = AXIS2_MSG_CTX_GET_SOAP_ENVELOPE(msg_ctx, env);
if (!envelope)
@@ -810,6 +809,7 @@
}
msg_ctx = axis2_msg_ctx_create(env, conf_ctx, NULL, NULL);
soap_env_str = sandesha2_msg_store_bean_get_soap_envelope_str(msg_store_bean, env);
+ printf("soap_env_str = %s\n", soap_env_str);
reader = axiom_xml_reader_create_for_memory(env, soap_env_str, AXIS2_STRLEN(
soap_env_str), NULL, AXIS2_XML_PARSER_TYPE_BUFFER);
om_builder = axiom_stax_builder_create(env, reader);
@@ -1008,6 +1008,7 @@
axis2_hash_this(index, &k, NULL, &v);
key = (axis2_char_t *) k;
property = (axis2_property_t *) v;
+ printf("key = %s\n", key);
AXIS2_MSG_CTX_SET_PROPERTY(msg_ctx, env, key, property,
AXIS2_FALSE);
}
Modified: webservices/sandesha/trunk/c/src/util/ack_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/ack_mgr.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/util/ack_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/ack_mgr.c Tue Feb 20 02:17:59 2007
@@ -219,7 +219,7 @@
old_ack_bean = AXIS2_ARRAY_LIST_GET(bean_list, env, i);
time_to_send = sandesha2_sender_bean_get_time_to_send(old_ack_bean,
env);
- axis2_char_t *msg_id = sandesha2_sender_bean_get_msg_id(old_ack_bean, env);
+ /*axis2_char_t *msg_id = sandesha2_sender_bean_get_msg_id((const sandesha2_sender_bean_t *)old_ack_bean, env);*/
sandesha2_sender_mgr_remove(retrans_mgr, env,
sandesha2_sender_bean_get_msg_id((sandesha2_rm_bean_t *)
old_ack_bean, env));
@@ -443,7 +443,7 @@
AXIS2_MSG_CTX_GET_TO(msg_ctx1, env), env);
if(0 == AXIS2_STRCMP(to, to_str))
continue;
- axis2_char_t *msg_id = sandesha2_sender_bean_get_msg_id(sender_bean, env);
+ /*axis2_char_t *msg_id = sandesha2_sender_bean_get_msg_id((const sandesha2_sender_bean_t *)sender_bean, env);*/
sandesha2_sender_mgr_remove(retrans_mgr, env,
sandesha2_sender_bean_get_msg_id((sandesha2_rm_bean_t *)
sender_bean, env));
Modified: webservices/sandesha/trunk/c/src/util/sandesha2_utils.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/sandesha2_utils.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/util/sandesha2_utils.c (original)
+++ webservices/sandesha/trunk/c/src/util/sandesha2_utils.c Tue Feb 20 02:17:59 2007
@@ -774,6 +774,8 @@
if(property)
AXIS2_MSG_CTX_SET_PROPERTY(new_msg, env, AXIS2_HTTP_OUT_TRANSPORT_INFO,
AXIS2_PROPERTY_CLONE(property, env), AXIS2_FALSE);
+ axis2_msg_ctx_set_http_out_transport_info(new_msg, env,
+ axis2_msg_ctx_get_http_out_transport_info(ref_msg, env));
property = AXIS2_MSG_CTX_GET_PROPERTY(ref_msg, env,
AXIS2_TRANSPORT_HEADERS, AXIS2_FALSE);
if(property)
Modified: webservices/sandesha/trunk/c/src/util/terminate_mgr.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/util/terminate_mgr.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/util/terminate_mgr.c (original)
+++ webservices/sandesha/trunk/c/src/util/terminate_mgr.c Tue Feb 20 02:17:59 2007
@@ -216,7 +216,6 @@
sandesha2_next_msg_bean_t *find_bean = NULL;
axis2_array_list_t *found_list = NULL;
axis2_char_t *highest_in_msg_key = NULL;
- int i = 0, size = 0;
AXIS2_LOG_INFO(env->log,
"[sandesha2]Entry:sandesha2_terminate_mgr_complete_termination_of_recv_side");
Modified: webservices/sandesha/trunk/c/src/workers/sender.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/workers/sender.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/workers/sender.c (original)
+++ webservices/sandesha/trunk/c/src/workers/sender.c Tue Feb 20 02:17:59 2007
@@ -262,7 +262,7 @@
sandesha2_sender_bean_t *sender_bean = NULL;
sandesha2_sender_worker_t *sender_worker = NULL;
axis2_char_t *msg_id = NULL;
- AXIS2_SLEEP(SANDESHA2_SENDER_SLEEP_TIME);
+ AXIS2_SLEEP(SANDESHA2_SENDER_SLEEP_TIME * 1);
transaction = sandesha2_storage_mgr_get_transaction(storage_mgr,
env);
mgr = sandesha2_storage_mgr_get_retrans_mgr(storage_mgr, env);
Modified: webservices/sandesha/trunk/c/src/workers/sender_worker.c
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/src/workers/sender_worker.c?view=diff&rev=509493&r1=509492&r2=509493
==============================================================================
--- webservices/sandesha/trunk/c/src/workers/sender_worker.c (original)
+++ webservices/sandesha/trunk/c/src/workers/sender_worker.c Tue Feb 20 02:17:59 2007
@@ -597,8 +597,6 @@
AXIOM_SOAP11_SOAP_ENVELOPE_NAMESPACE_URI:
AXIOM_SOAP12_SOAP_ENVELOPE_NAMESPACE_URI;
- /*res_envelope = axis2_http_transport_utils_create_soap_msg(env, msg_ctx,
- soap_ns_uri);*/
res_envelope = axis2_msg_ctx_get_response_soap_envelope(msg_ctx, env);
if(!res_envelope)
res_envelope = axis2_http_transport_utils_create_soap_msg(env, msg_ctx,
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org