You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by da...@apache.org on 2006/12/06 13:35:56 UTC
svn commit: r483056 - in /webservices/sandesha/trunk/c/include: ./ sandesha2/
Author: damitha
Date: Wed Dec 6 04:35:53 2006
New Revision: 483056
URL: http://svn.apache.org/viewvc?view=rev&rev=483056
Log:
Creating an abstraction layer for storage
Added:
webservices/sandesha/trunk/c/include/sandesha2_inmemory_create_seq_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_inmemory_invoker_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_inmemory_next_msg_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_inmemory_sender_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_inmemory_seq_property_mgr.h
Modified:
webservices/sandesha/trunk/c/include/sandesha2/sandesha2_transaction.h
webservices/sandesha/trunk/c/include/sandesha2_client.h
webservices/sandesha/trunk/c/include/sandesha2_constants.h
webservices/sandesha/trunk/c/include/sandesha2_create_seq_bean.h
webservices/sandesha/trunk/c/include/sandesha2_create_seq_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_identifier.h
webservices/sandesha/trunk/c/include/sandesha2_invoker_bean.h
webservices/sandesha/trunk/c/include/sandesha2_invoker_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_make_connection_msg_processor.h
webservices/sandesha/trunk/c/include/sandesha2_msg_pending.h
webservices/sandesha/trunk/c/include/sandesha2_next_msg_bean.h
webservices/sandesha/trunk/c/include/sandesha2_next_msg_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_sender_bean.h
webservices/sandesha/trunk/c/include/sandesha2_sender_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_seq_property_bean.h
webservices/sandesha/trunk/c/include/sandesha2_seq_property_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_storage_mgr.h
webservices/sandesha/trunk/c/include/sandesha2_transaction.h
webservices/sandesha/trunk/c/include/sandesha2_utils.h
Modified: webservices/sandesha/trunk/c/include/sandesha2/sandesha2_transaction.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2/sandesha2_transaction.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2/sandesha2_transaction.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2/sandesha2_transaction.h Wed Dec 6 04:35:53 2006
@@ -76,13 +76,13 @@
const axis2_env_t *env);
/************************** Start of function macros **************************/
-#define SANDESHA2_TRANSACTION_FREE(transaction, env) \
+#define sandesha2_transaction_free(transaction, env) \
((transaction)->ops->free (transaction, env))
-#define SANDESHA2_TRANSACTION_COMMIT(transaction, env) \
+#define sandesha2_transaction_commit(transaction, env) \
((transaction)->ops->commit(transaction, env))
-#define SANDESHA2_TRANSACTION_ROLLBACK(transaction, env) \
+#define sandesha2_transaction_rollback(transaction, env) \
((transaction)->ops->rollback(transaction, env))
/************************** End of function macros ****************************/
Modified: webservices/sandesha/trunk/c/include/sandesha2_client.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_client.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_client.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_client.h Wed Dec 6 04:35:53 2006
@@ -31,6 +31,8 @@
#include <axis2_uri.h>
#include <axis2_array_list.h>
#include <axis2_svc_client.h>
+#include <axis2_callback.h>
+#include <axis2_listener_manager.h>
#include <sandesha2_seq_report.h>
#include <sandesha2_report.h>
@@ -46,21 +48,21 @@
*/
sandesha2_seq_report_t *AXIS2_CALL
sandesha2_client_get_outgoing_seq_report_with_svc_client(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client);
sandesha2_seq_report_t *AXIS2_CALL
sandesha2_client_get_outgoing_seq_report_with_seq_key(
- const axis2_env_t *env,
- axis2_char_t *to,
- axis2_char_t *seq_key,
- axis2_conf_ctx_t *conf_ctx);
+ const axis2_env_t *env,
+ axis2_char_t *to,
+ axis2_char_t *seq_key,
+ axis2_conf_ctx_t *conf_ctx);
sandesha2_seq_report_t *AXIS2_CALL
sandesha2_client_get_outgoing_seq_report_with_internal_seq_id(
- const axis2_env_t *env,
- axis2_char_t *internal_seq_id,
- axis2_conf_ctx_t *conf_ctx);
+ const axis2_env_t *env,
+ axis2_char_t *internal_seq_id,
+ axis2_conf_ctx_t *conf_ctx);
/**
* Users can get a list of seq_reports each describing a incoming
@@ -72,8 +74,8 @@
*/
axis2_array_list_t *AXIS2_CALL
sandesha2_client_get_incoming_seq_reports(
- axis2_env_t *env,
- axis2_conf_ctx_t *conf_ctx);
+ axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
/**
* sandesha2_report gives the details of all incoming and outgoing sequences.
@@ -85,21 +87,21 @@
*/
sandesha2_report_t *AXIS2_CALL
sandesha2_client_get_report(
- const axis2_env_t *env,
- axis2_conf_ctx_t *conf_ctx);
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
axis2_status_t AXIS2_CALL
sandesha2_client_create_seq_with_svc_client(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- axis2_bool_t offer);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_bool_t offer);
axis2_status_t AXIS2_CALL
sandesha2_client_create_seq_with_svc_client_and_seq_key(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- axis2_bool_t offer,
- axis2_char_t *seq_key);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_bool_t offer,
+ axis2_char_t *seq_key);
/**
* User can terminate the sequence defined by the passed svc_client.
@@ -108,14 +110,16 @@
*/
axis2_status_t AXIS2_CALL
sandesha2_client_terminate_seq_with_svc_client(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_callback_t *callback,
+ axis2_listener_manager_t *listener_manager);
axis2_status_t AXIS2_CALL
sandesha2_client_terminate_seq_with_svc_client_and_seq_key(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- axis2_char_t *seq_key);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_char_t *seq_key);
/**
* User can close the seq defined by the passed svc_client.
@@ -124,14 +128,14 @@
*/
axis2_status_t AXIS2_CALL
sandesha2_client_close_seq_with_svc_client(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client);
axis2_status_t AXIS2_CALL
sandesha2_client_close_seq_with_svc_client_and_seq_key(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- axis2_char_t *seq_key);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_char_t *seq_key);
/**
* This blocks the system until the messages sent have been completed.
@@ -140,14 +144,14 @@
*/
axis2_status_t AXIS2_CALL
sandesha2_client_wait_until_seq_completed_with_svc_client(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client);
axis2_status_t AXIS2_CALL
sandesha2_client_wait_until_seq_completed_with_svc_client_and_seq_key(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- axis2_char_t *seq_key);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_char_t *seq_key);
/**
* This blocks the system until the messages sent have been completed
@@ -158,35 +162,55 @@
*/
axis2_status_t AXIS2_CALL
sandesha2_client_wait_until_seq_completed_with_svc_client_and_max_waiting_time(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- long max_waiting_time);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ long max_waiting_time);
axis2_status_t AXIS2_CALL
sandesha2_client_wait_until_seq_completed_with_svc_client_and_max_waiting_time_and_seq_key(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- long max_waiting_time,
- axis2_char_t *seq_key);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ long max_waiting_time,
+ axis2_char_t *seq_key);
/*
* gives the out seqID if CS/CSR exchange is done. Otherwise an error
*/
axis2_char_t *AXIS2_CALL
sandesha2_client_get_seq_id(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client);
axis2_status_t AXIS2_CALL
sandesha2_client_send_ack_request_with_svc_client(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client);
axis2_status_t AXIS2_CALL
sandesha2_client_send_ack_request_with_svc_client_and_seq_key(
- const axis2_env_t *env,
- axis2_svc_client_t *svc_client,
- axis2_char_t *seq_key);
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_char_t *seq_key);
+
+axis2_status_t AXIS2_CALL
+sandesha2_client_send_non_blocking(
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_options_t *options,
+ axis2_qname_t *op_qname,
+ axis2_callback_t *callback,
+ axiom_node_t *payload,
+ axis2_listener_manager_t *listener_manager);
+
+void AXIS2_CALL
+sandesha2_client_fire_and_forget(
+ const axis2_env_t *env,
+ axis2_svc_client_t *svc_client,
+ axis2_options_t *options,
+ axis2_qname_t *op_qname,
+ axis2_callback_t *callback,
+ axiom_node_t *payload,
+ axis2_listener_manager_t *listener_manager);
#ifdef __cplusplus
}
Modified: webservices/sandesha/trunk/c/include/sandesha2_constants.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_constants.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_constants.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_constants.h Wed Dec 6 04:35:53 2006
@@ -75,7 +75,7 @@
#define SANDESHA2_SPEC_2006_08_ACTION_CLOSE_SEQ "http://docs.oasis-open.org/ws-rx/wsrm/200608/CloseSequence"
#define SANDESHA2_SPEC_2006_08_ACTION_CLOSE_SEQ_RESPONSE "http://docs.oasis-open.org/ws-rx/wsrm/200608/CloseSequenceResponse"
- #define SANDESHA2_SPEC_2006_08_ACTION_MAKE_CONNECTION "http://docs.oasisopen.org/ws-rx/wsrm/200608/MakeConnection"
+ #define SANDESHA2_SPEC_2006_08_ACTION_MAKE_CONNECTION "http://docs.oasis-open.org/ws-rx/wsrm/200608/MakeConnection"
#define SANDESHA2_SPEC_2006_08_SOAP_ACTION_CREATE_SEQ "http://docs.oasis-open.org/ws-rx/wsrm/200608/CreateSequence"
@@ -168,18 +168,18 @@
enum sandesha2_message_types
{
SANDESHA2_MSG_TYPE_UNKNOWN = 0,
- SANDESHA2_MSG_TYPE_CREATE_SEQ,
- SANDESHA2_MSG_TYPE_CREATE_SEQ_RESPONSE,
- SANDESHA2_MSG_TYPE_APPLICATION,
- SANDESHA2_MSG_TYPE_ACK,
- SANDESHA2_MSG_TYPE_CLOSE_SEQ,
- SANDESHA2_MSG_TYPE_CLOSE_SEQ_RESPONSE,
- SANDESHA2_MSG_TYPE_TERMINATE_SEQ,
- SANDESHA2_MSG_TYPE_ACK_REQUEST,
- SANDESHA2_MSG_TYPE_TERMINATE_SEQ_RESPONSE,
- SANDESHA2_MSG_TYPE_FAULT_MSG,
- SANDESHA2_MSG_TYPE_MAX_MESSAGE_TYPE,
- SANDESHA2_MSG_TYPE_MAKE_CONNECTION_MSG
+ SANDESHA2_MSG_TYPE_CREATE_SEQ, /* 1 */
+ SANDESHA2_MSG_TYPE_CREATE_SEQ_RESPONSE, /* 2 */
+ SANDESHA2_MSG_TYPE_APPLICATION, /* 3 */
+ SANDESHA2_MSG_TYPE_ACK, /* 4 */
+ SANDESHA2_MSG_TYPE_CLOSE_SEQ, /* 5 */
+ SANDESHA2_MSG_TYPE_CLOSE_SEQ_RESPONSE, /* 6 */
+ SANDESHA2_MSG_TYPE_TERMINATE_SEQ, /* 7 */
+ SANDESHA2_MSG_TYPE_ACK_REQUEST, /* 8 */
+ SANDESHA2_MSG_TYPE_TERMINATE_SEQ_RESPONSE, /* 9 */
+ SANDESHA2_MSG_TYPE_FAULT_MSG, /* 10 */
+ SANDESHA2_MSG_TYPE_MAX_MESSAGE_TYPE, /* 11 */
+ SANDESHA2_MSG_TYPE_MAKE_CONNECTION_MSG /* 12 */
};
enum sandesha2_message_parts
@@ -407,11 +407,13 @@
#define SANDESHA2_ACK_WRITTEN "AckWritten"
- #define SANDESHA2_INVOKER_SLEEP_TIME 1000
+ #define SANDESHA2_INVOKER_SLEEP_TIME 2
- #define SANDESHA2_SENDER_SLEEP_TIME 500
+ #define SANDESHA2_SENDER_SLEEP_TIME 3
- #define SANDESHA2_CLIENT_SLEEP_TIME 10000
+ #define SANDESHA2_POLLING_MANAGER_WAIT_TIME 6
+
+ #define SANDESHA2_CLIENT_SLEEP_TIME 32
#define SANDESHA2_TERMINATE_DELAY 100
@@ -465,6 +467,8 @@
#define SANDESHA2_SENDER "Sender"
#define SANDESHA2_INVOKER "Invoker"
+
+ #define SANDESHA2_POLLING_MGR "PollingManager"
#define SANDESHA2_WITHIN_TRANSACTION "WithinTransaction"
Modified: webservices/sandesha/trunk/c/include/sandesha2_create_seq_bean.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_create_seq_bean.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_create_seq_bean.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_create_seq_bean.h Wed Dec 6 04:35:53 2006
@@ -21,7 +21,6 @@
#include <axis2_env.h>
#include <axis2_utils.h>
#include <axis2_utils_defines.h>
-#include <string.h>
#ifdef __cplusplus
extern "C"
@@ -29,6 +28,7 @@
#endif
typedef struct sandesha2_create_seq_bean_t sandesha2_create_seq_bean_t;
+struct sandesha2_rm_bean_t;
/* constructors
*/
@@ -48,6 +48,17 @@
sandesha2_create_seq_bean_t *create_seq,
const axis2_env_t *env);
+struct sandesha2_rm_bean_t * AXIS2_CALL
+sandesha2_create_seq_bean_get_base(
+ sandesha2_create_seq_bean_t* create_seq,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_create_seq_bean_set_base (
+ sandesha2_create_seq_bean_t *create_seq,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t* rm_bean);
+
axis2_char_t* AXIS2_CALL
sandesha2_create_seq_bean_get_create_seq_msg_id (
sandesha2_create_seq_bean_t *create_seq,
@@ -56,7 +67,8 @@
void AXIS2_CALL
sandesha2_create_seq_bean_set_create_seq_msg_id (
sandesha2_create_seq_bean_t *create_seq,
- const axis2_env_t *env, axis2_char_t* seq_msg_id) ;
+ const axis2_env_t *env,
+ axis2_char_t* seq_msg_id) ;
axis2_char_t* AXIS2_CALL
sandesha2_create_seq_bean_get_seq_id (
@@ -66,7 +78,8 @@
void AXIS2_CALL
sandesha2_create_seq_bean_set_seq_id (
sandesha2_create_seq_bean_t *create_seq,
- const axis2_env_t *env, axis2_char_t* seq_id) ;
+ const axis2_env_t *env,
+ axis2_char_t* seq_id) ;
axis2_char_t* AXIS2_CALL
sandesha2_create_seq_bean_get_internal_seq_id (
@@ -76,7 +89,8 @@
void AXIS2_CALL
sandesha2_create_seq_bean_set_internal_seq_id (
sandesha2_create_seq_bean_t *create_seq,
- const axis2_env_t *env, axis2_char_t* int_seq_id);
+ const axis2_env_t *env,
+ axis2_char_t* int_seq_id);
axis2_char_t * AXIS2_CALL
sandesha2_create_seq_bean_get_create_seq_msg_store_key(
@@ -86,7 +100,8 @@
void AXIS2_CALL
sandesha2_create_seq_bean_set_create_seq_msg_store_key(
sandesha2_create_seq_bean_t *create_seq,
- const axis2_env_t *env, axis2_char_t *create_seq_msg_store_key);
+ const axis2_env_t *env,
+ axis2_char_t *create_seq_msg_store_key);
axis2_char_t * AXIS2_CALL
sandesha2_create_seq_bean_get_ref_msg_store_key(
@@ -96,7 +111,8 @@
void AXIS2_CALL
sandesha2_create_seq_bean_set_ref_msg_store_key(
sandesha2_create_seq_bean_t *create_seq,
- const axis2_env_t *env, axis2_char_t *ref_msg_store_key);
+ const axis2_env_t *env,
+ axis2_char_t *ref_msg_store_key);
Modified: webservices/sandesha/trunk/c/include/sandesha2_create_seq_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_create_seq_mgr.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_create_seq_mgr.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_create_seq_mgr.h Wed Dec 6 04:35:53 2006
@@ -101,35 +101,49 @@
AXIS2_EXTERN sandesha2_create_seq_mgr_t * AXIS2_CALL
sandesha2_create_seq_mgr_create(
- const axis2_env_t *env,
- axis2_ctx_t *ctx);
+ const axis2_env_t *env,
+ axis2_ctx_t *ctx);
-#define SANDESHA2_CREATE_SEQ_MGR_FREE(seq_mgr, env) \
- (((sandesha2_create_seq_mgr_t *) seq_mgr)->ops->free (seq_mgr, env))
-
-#define SANDESHA2_CREATE_SEQ_MGR_INSERT(seq_mgr, env, bean) \
- (((sandesha2_create_seq_mgr_t *) seq_mgr)->ops->\
- insert (seq_mgr, env, bean))
-
-#define SANDESHA2_CREATE_SEQ_MGR_REMOVE(seq_mgr, env, msg_id) \
- (((sandesha2_create_seq_mgr_t *) seq_mgr)->ops->\
- remove (seq_mgr, env, msg_id))
-
-#define SANDESHA2_CREATE_SEQ_MGR_RETRIEVE(seq_mgr, env, msg_id) \
- (((sandesha2_create_seq_mgr_t *) seq_mgr)->ops->\
- retrieve (seq_mgr, env, msg_id))
-
-#define SANDESHA2_CREATE_SEQ_MGR_UPDATE(seq_mgr, env, bean) \
- (((sandesha2_create_seq_mgr_t *) seq_mgr)->ops->\
- update (seq_mgr, env, bean))
-
-#define SANDESHA2_CREATE_SEQ_MGR_FIND(seq_mgr, env, bean) \
- (((sandesha2_create_seq_mgr_t *) seq_mgr)->ops->\
- find (seq_mgr, env, bean))
-
-#define SANDESHA2_CREATE_SEQ_MGR_FIND_UNIQUE(seq_mgr, env, bean) \
- (((sandesha2_create_seq_mgr_t *) seq_mgr)->ops->\
- find_unique (seq_mgr, env, bean))
+axis2_status_t AXIS2_CALL
+sandesha2_create_seq_mgr_free(
+ sandesha2_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env);
+
+axis2_bool_t AXIS2_CALL
+sandesha2_create_seq_mgr_insert(
+ sandesha2_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
+
+axis2_bool_t AXIS2_CALL
+sandesha2_create_seq_mgr_remove(
+ sandesha2_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *msg_id);
+
+sandesha2_create_seq_bean_t *AXIS2_CALL
+sandesha2_create_seq_mgr_retrieve(
+ sandesha2_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ const axis2_char_t *msg_id);
+
+axis2_bool_t AXIS2_CALL
+sandesha2_create_seq_mgr_update(
+ sandesha2_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
+
+axis2_array_list_t *AXIS2_CALL
+sandesha2_create_seq_mgr_find(
+ sandesha2_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
+
+sandesha2_create_seq_bean_t *AXIS2_CALL
+sandesha2_create_seq_mgr_find_unique(
+ sandesha2_create_seq_mgr_t *seq_mgr,
+ const axis2_env_t *env,
+ sandesha2_create_seq_bean_t *bean);
/** @} */
Modified: webservices/sandesha/trunk/c/include/sandesha2_identifier.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_identifier.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_identifier.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_identifier.h Wed Dec 6 04:35:53 2006
@@ -62,7 +62,8 @@
axis2_status_t AXIS2_CALL
sandesha2_identifier_set_identifier(
sandesha2_identifier_t *identifier,
- const axis2_env_t *env, axis2_char_t *str_id);
+ const axis2_env_t *env,
+ axis2_char_t *str_id);
/** @} */
Added: webservices/sandesha/trunk/c/include/sandesha2_inmemory_create_seq_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_inmemory_create_seq_mgr.h?view=auto&rev=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_inmemory_create_seq_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_inmemory_create_seq_mgr.h Wed Dec 6 04:35:53 2006
@@ -0,0 +1,52 @@
+/*
+ * 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 SANDESHA2_INMEMORY_CREATE_SEQ_MGR_H
+#define SANDESHA2_INMEMORY_CREATE_SEQ_MGR_H
+
+/**
+ * @file sandesha2_inmemory_create_seq_mgr.h
+ * @brief Sandesha In Memory Create Sequence Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+struct axis2_ctx;
+
+/** @defgroup sandesha2_inmemory_create_seq_mgr In Memory Create Sequence Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+AXIS2_EXTERN sandesha2_create_seq_mgr_t * AXIS2_CALL
+sandesha2_inmemory_create_seq_mgr_create(
+ const axis2_env_t *env,
+ struct axis2_ctx *ctx);
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_INMEMORY_CREATE_SEQ_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_inmemory_invoker_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_inmemory_invoker_mgr.h?view=auto&rev=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_inmemory_invoker_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_inmemory_invoker_mgr.h Wed Dec 6 04:35:53 2006
@@ -0,0 +1,52 @@
+/*
+ * 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 SANDESHA2_INMEMORY_INVOKER_MGR_H
+#define SANDESHA2_INMEMORY_INVOKER_MGR_H
+
+/**
+ * @file sandesha2_inmemory_invoker_mgr.h
+ * @brief Sandesha In Memory Invoker Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+struct axis2_ctx;
+
+/** @defgroup sandesha2_inmemory_invoker_mgr In Memory Invoker Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+AXIS2_EXTERN sandesha2_invoker_mgr_t * AXIS2_CALL
+sandesha2_inmemory_invoker_mgr_create(
+ const axis2_env_t *env,
+ struct axis2_ctx *ctx);
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_INMEMORY_INVOKER_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_inmemory_next_msg_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_inmemory_next_msg_mgr.h?view=auto&rev=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_inmemory_next_msg_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_inmemory_next_msg_mgr.h Wed Dec 6 04:35:53 2006
@@ -0,0 +1,52 @@
+/*
+ * 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 SANDESHA2_INMEMORY_NEXT_MSG_MGR_H
+#define SANDESHA2_INMEMORY_NEXT_MSG_MGR_H
+
+/**
+ * @file sandesha2_inmemory_next_msg_mgr.h
+ * @brief Sandesha In Memory Next Message Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+struct axis2_ctx;
+
+/** @defgroup sandesha2_inmemory_next_msg_mgr In Memory Next Message Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+AXIS2_EXTERN sandesha2_next_msg_mgr_t * AXIS2_CALL
+sandesha2_inmemory_next_msg_mgr_create(
+ const axis2_env_t *env,
+ struct axis2_ctx *ctx);
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_INMEMORY_NEXT_MSG_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_inmemory_sender_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_inmemory_sender_mgr.h?view=auto&rev=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_inmemory_sender_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_inmemory_sender_mgr.h Wed Dec 6 04:35:53 2006
@@ -0,0 +1,52 @@
+/*
+ * 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 SANDESHA2_INMEMORY_SENDER_MGR_H
+#define SANDESHA2_INMEMORY_SENDER_MGR_H
+
+/**
+ * @file sandesha2_inmemory_sender_mgr.h
+ * @brief Sandesha In Memory Sender Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+struct axis2_ctx;
+
+/** @defgroup sandesha2_inmemory_sender_mgr In Memory Sender Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+AXIS2_EXTERN sandesha2_sender_mgr_t * AXIS2_CALL
+sandesha2_inmemory_sender_mgr_create(
+ const axis2_env_t *env,
+ struct axis2_ctx *ctx);
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_INMEMORY_SENDER_MGR_H */
Added: webservices/sandesha/trunk/c/include/sandesha2_inmemory_seq_property_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_inmemory_seq_property_mgr.h?view=auto&rev=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_inmemory_seq_property_mgr.h (added)
+++ webservices/sandesha/trunk/c/include/sandesha2_inmemory_seq_property_mgr.h Wed Dec 6 04:35:53 2006
@@ -0,0 +1,53 @@
+/*
+ * 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 SANDESHA2_INMEMORY_SEQ_PROPERTY_MGR_H
+#define SANDESHA2_INMEMORY_SEQ_PROPERTY_MGR_H
+
+/**
+ * @file sandesha2_inmemory_seq_property_mgr.h
+ * @brief Sandesha In Memory Sequence Property Manager Interface
+ */
+
+#include <axis2_allocator.h>
+#include <axis2_env.h>
+#include <axis2_error.h>
+#include <axis2_string.h>
+#include <axis2_utils.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+struct axis2_ctx;
+
+/** @defgroup sandesha2_inmemory_seq_property_mgr In Memory Sequence Property
+ * Manager
+ * @ingroup sandesha2
+ * @{
+ */
+
+AXIS2_EXTERN sandesha2_seq_property_mgr_t * AXIS2_CALL
+sandesha2_inmemory_seq_property_mgr_create(
+ const axis2_env_t *env,
+ struct axis2_ctx *ctx);
+
+/** @} */
+#ifdef __cplusplus
+}
+#endif
+#endif /* SANDESHA2_INMEMORY_SEQ_PROPERTY_MGR_H */
Modified: webservices/sandesha/trunk/c/include/sandesha2_invoker_bean.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_invoker_bean.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_invoker_bean.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_invoker_bean.h Wed Dec 6 04:35:53 2006
@@ -27,6 +27,7 @@
#endif
typedef struct sandesha2_invoker_bean_t sandesha2_invoker_bean_t;
+struct sandesha2_rm_bean_t;
/* constructors
*/
@@ -45,6 +46,17 @@
sandesha2_invoker_bean_free (
sandesha2_invoker_bean_t *invoker,
const axis2_env_t *env);
+
+struct sandesha2_rm_bean_t * AXIS2_CALL
+sandesha2_invoker_bean_get_base(
+ sandesha2_invoker_bean_t* invoker,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_invoker_bean_set_base (
+ sandesha2_invoker_bean_t *invoker,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t* rm_bean);
axis2_char_t* AXIS2_CALL
sandesha2_invoker_bean_get_msg_ctx_ref_key(
Modified: webservices/sandesha/trunk/c/include/sandesha2_invoker_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_invoker_mgr.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_invoker_mgr.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_invoker_mgr.h Wed Dec 6 04:35:53 2006
@@ -36,7 +36,62 @@
{
#endif
-typedef struct sandesha2_invoker_mgr_t sandesha2_invoker_mgr_t;
+typedef struct sandesha2_invoker_mgr sandesha2_invoker_mgr_t;
+typedef struct sandesha2_invoker_mgr_ops sandesha2_invoker_mgr_ops_t;
+
+struct sandesha2_sender_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free)(
+ sandesha2_invoker_mgr_t *invoker,
+ const axis2_env_t *envv);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert)(
+ sandesha2_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove)(
+ sandesha2_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ axis2_char_t *ref_key);
+
+ sandesha2_invoker_bean_t *(AXIS2_CALL *
+ retrieve)(
+ sandesha2_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ axis2_char_t *ref_key);
+
+ axis2_bool_t (AXIS2_CALL *
+ update)(
+ sandesha2_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find)(
+ sandesha2_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+ sandesha2_invoker_bean_t *(AXIS2_CALL *
+ find_unique)(
+ sandesha2_invoker_mgr_t *invoker,
+ const axis2_env_t *env,
+ sandesha2_invoker_bean_t *bean);
+
+};
+
+struct sandesha2_invoker_mgr
+{
+ sandesha2_invoker_mgr_ops_t *ops;
+};
AXIS2_EXTERN sandesha2_invoker_mgr_t * AXIS2_CALL
sandesha2_invoker_mgr_create(
Modified: webservices/sandesha/trunk/c/include/sandesha2_make_connection_msg_processor.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_make_connection_msg_processor.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_make_connection_msg_processor.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_make_connection_msg_processor.h Wed Dec 6 04:35:53 2006
@@ -18,7 +18,7 @@
#define SANDESHA2_MAKE_CONNECTION_MSG_PROCESSOR_H
/**
- * @file sandesha2_make_connnection_msg_processor.h
+ * @file sandesha2_make_connection_msg_processor.h
* @brief
* This struct is responsible for processing MakeConnection request messages
* that come to the system. MakeConnection is only supported by WSRM 1.1
@@ -36,13 +36,13 @@
{
#endif
-/** @defgroup sandesha2_make_connnection_msg_processor
+/** @defgroup sandesha2_make_connection_msg_processor
* @ingroup sandesha2_msgprocessors
* @{
*/
AXIS2_EXTERN sandesha2_msg_processor_t* AXIS2_CALL
-sandesha2_make_connnection_msg_processor_create(
+sandesha2_make_connection_msg_processor_create(
const axis2_env_t *env);
/** @} */
#ifdef __cplusplus
Modified: webservices/sandesha/trunk/c/include/sandesha2_msg_pending.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_msg_pending.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_msg_pending.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_msg_pending.h Wed Dec 6 04:35:53 2006
@@ -69,6 +69,12 @@
const axis2_env_t *env,
axis2_bool_t pending);
+axis2_status_t AXIS2_CALL
+sandesha2_msg_pending_to_soap_envelope(
+ sandesha2_iom_rm_part_t *msg_pending,
+ const axis2_env_t *env,
+ axiom_soap_envelope_t *envelope);
+
/** @} */
#ifdef __cplusplus
Modified: webservices/sandesha/trunk/c/include/sandesha2_next_msg_bean.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_next_msg_bean.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_next_msg_bean.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_next_msg_bean.h Wed Dec 6 04:35:53 2006
@@ -18,6 +18,7 @@
#define SANDESHA2_NEXT_MSG_BEAN_H
#include <axis2_utils_defines.h>
+struct sandesha2_rm_bean_t;
#include <axis2_env.h>
#ifdef __cplusplus
@@ -42,6 +43,17 @@
sandesha2_next_msg_bean_free (
sandesha2_next_msg_bean_t *next_msg_bean,
const axis2_env_t *env);
+
+struct sandesha2_rm_bean_t * AXIS2_CALL
+sandesha2_next_msg_bean_get_base(
+ sandesha2_next_msg_bean_t* next_msg,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_next_msg_bean_set_base (
+ sandesha2_next_msg_bean_t *next_msg,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t* rm_bean);
axis2_char_t* AXIS2_CALL
sandesha2_next_msg_bean_get_seq_id(
Modified: webservices/sandesha/trunk/c/include/sandesha2_next_msg_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_next_msg_mgr.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_next_msg_mgr.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_next_msg_mgr.h Wed Dec 6 04:35:53 2006
@@ -36,7 +36,66 @@
{
#endif
-typedef struct sandesha2_next_msg_mgr_t sandesha2_next_msg_mgr_t;
+typedef struct sandesha2_next_msg_mgr sandesha2_next_msg_mgr_t;
+typedef struct sandesha2_next_msg_mgr_ops sandesha2_next_msg_mgr_ops_t;
+
+struct sandesha2_next_msg_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ axis2_char_t *seq_id);
+
+ sandesha2_next_msg_bean_t *(AXIS2_CALL *
+ retrieve)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ axis2_char_t *seq_id);
+
+ axis2_bool_t (AXIS2_CALL *
+ update)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ sandesha2_next_msg_bean_t *(AXIS2_CALL *
+ find_unique)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env,
+ sandesha2_next_msg_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ retrieve_all)(
+ sandesha2_next_msg_mgr_t *next_msg,
+ const axis2_env_t *env);
+}
+
+struct sandesha2_next_msg_mgr
+{
+ sandesha2_next_msg_mgr_ops_t *ops;
+};
AXIS2_EXTERN sandesha2_next_msg_mgr_t * AXIS2_CALL
sandesha2_next_msg_mgr_create(
Modified: webservices/sandesha/trunk/c/include/sandesha2_sender_bean.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_sender_bean.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_sender_bean.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_sender_bean.h Wed Dec 6 04:35:53 2006
@@ -26,6 +26,7 @@
#endif
typedef struct sandesha2_sender_bean_t sandesha2_sender_bean_t;
+struct sandesha2_rm_bean_t;
/* constructors
*/
@@ -48,6 +49,17 @@
sandesha2_sender_bean_t *sender,
const axis2_env_t *env);
+struct sandesha2_rm_bean_t * AXIS2_CALL
+sandesha2_sender_bean_get_base(
+ sandesha2_sender_bean_t* sender,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_sender_bean_set_base (
+ sandesha2_sender_bean_t *sender,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t* rm_bean);
+
axis2_char_t* AXIS2_CALL
sandesha2_sender_bean_get_msg_ctx_ref_key (
sandesha2_sender_bean_t *sender,
@@ -169,6 +181,16 @@
const axis2_env_t *env,
axis2_char_t *anon_uri);
+void AXIS2_CALL
+sandesha2_sender_bean_set_to_address (
+ sandesha2_sender_bean_t *sender,
+ const axis2_env_t *env,
+ axis2_char_t *to_address);
+
+axis2_char_t* AXIS2_CALL
+sandesha2_sender_bean_get_to_address(
+ sandesha2_sender_bean_t *sender,
+ const axis2_env_t *env);
#ifdef __cplusplus
}
Modified: webservices/sandesha/trunk/c/include/sandesha2_sender_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_sender_mgr.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_sender_mgr.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_sender_mgr.h Wed Dec 6 04:35:53 2006
@@ -36,7 +36,78 @@
{
#endif
-typedef struct sandesha2_sender_mgr_t sandesha2_sender_mgr_t;
+typedef struct sandesha2_sender_mgr sandesha2_sender_mgr_t;
+typedef struct sandesha2_sender_mgr_ops sandesha2_sender_mgr_ops_t;
+
+struct sandesha2_sender_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *envv);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ const axis2_char_t *msg_id);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ retrieve)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ const axis2_char_t *msg_id);
+
+ axis2_bool_t (AXIS2_CALL *
+ update)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find_by_internal_seq_id)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ axis2_char_t *internal_seq_id);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find_by_sender_bean)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ find_unique)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ sandesha2_sender_bean_t *bean);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ get_next_msg_to_send)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env);
+
+ sandesha2_sender_bean_t *(AXIS2_CALL *
+ retrieve_from_msg_ref_key)(
+ sandesha2_sender_mgr_t *sender,
+ const axis2_env_t *env,
+ axis2_char_t *msg_ctx_ref_key);
+}
+
+struct sandesha2_sender_mgr
+{
+ sandesha2_sender_mgr_ops_t *ops;
+};
AXIS2_EXTERN sandesha2_sender_mgr_t * AXIS2_CALL
sandesha2_sender_mgr_create(
Modified: webservices/sandesha/trunk/c/include/sandesha2_seq_property_bean.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_seq_property_bean.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_seq_property_bean.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_seq_property_bean.h Wed Dec 6 04:35:53 2006
@@ -26,6 +26,7 @@
#endif
typedef struct sandesha2_seq_property_bean_t sandesha2_seq_property_bean_t ;
+struct sandesha2_rm_bean_t;
/* constructors
*/
@@ -45,6 +46,17 @@
sandesha2_seq_property_bean_free (
sandesha2_seq_property_bean_t *seq_property,
const axis2_env_t *env);
+
+struct sandesha2_rm_bean_t * AXIS2_CALL
+sandesha2_seq_property_bean_get_base(
+ sandesha2_seq_property_bean_t* seq_property,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_seq_property_bean_set_base (
+ sandesha2_seq_property_bean_t *seq_property,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t* rm_bean);
axis2_char_t *AXIS2_CALL
sandesha2_seq_property_bean_get_name (
Modified: webservices/sandesha/trunk/c/include/sandesha2_seq_property_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_seq_property_mgr.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_seq_property_mgr.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_seq_property_mgr.h Wed Dec 6 04:35:53 2006
@@ -36,7 +36,75 @@
{
#endif
-typedef struct sandesha2_seq_property_mgr_t sandesha2_seq_property_mgr_t;
+typedef struct sandesha2_seq_property_mgr sandesha2_seq_property_mgr_t;
+typedef struct sandesha2_seq_property_mgr_ops sandesha2_seq_property_mgr_ops_t;
+
+struct sandesha2_seq_property_mgr_ops
+{
+ /**
+ * Deallocate memory
+ * @return status code
+ */
+ axis2_status_t (AXIS2_CALL *
+ free)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *envv);
+
+ axis2_bool_t (AXIS2_CALL *
+ insert)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_seq_property_bean_t *bean);
+
+ axis2_bool_t (AXIS2_CALL *
+ remove)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ axis2_char_t *seq_id,
+ axis2_char_t *name);
+
+ sandesha2_seq_property_bean_t *(AXIS2_CALL *
+ retrieve)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ axis2_char_t *seq_id,
+ axis2_char_t *name);
+
+ axis2_bool_t (AXIS2_CALL *
+ update)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_seq_property_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ find)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_seq_property_bean_t *bean);
+
+ sandesha2_seq_property_bean_t *(AXIS2_CALL *
+ find_unique)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_seq_property_bean_t *bean);
+
+ axis2_array_list_t *(AXIS2_CALL *
+ retrieve_all)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ update_or_insert)(
+ sandesha2_seq_property_mgr_t *seq_property,
+ const axis2_env_t *env,
+ sandesha2_seq_property_bean_t *bean);
+
+}
+
+struct sandesha2_seq_property_mgr
+{
+ sandesha2_seq_property_mgr_ops_t *ops;
+};
AXIS2_EXTERN sandesha2_seq_property_mgr_t * AXIS2_CALL
sandesha2_seq_property_mgr_create(
Modified: webservices/sandesha/trunk/c/include/sandesha2_storage_mgr.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_storage_mgr.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_storage_mgr.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_storage_mgr.h Wed Dec 6 04:35:53 2006
@@ -41,11 +41,134 @@
#endif
/**
- * @ingroup sandesha2_storage_mgr
+ * @ingroup sandesha2_storage
* @{
*/
-typedef struct sandesha2_storage_mgr_t sandesha2_storage_mgr_t;
+typedef struct sandesha2_storage_mgr sandesha2_storage_mgr_t;
+typedef struct sandesha2_storage_mgr_ops sandesha2_storage_mgr_ops_t;
+struct sandesha2_rm_bean;
+
+ /**
+ * @brief Storage Manager ops struct
+ * Encapsulator struct for ops of sandesha2_storage_mgr
+ */
+AXIS2_DECLARE_DATA struct sandesha2_storage_mgr_ops
+{
+ axis2_status_t (AXIS2_CALL *
+ free)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *envv);
+
+ AXIS2_EXTERN axis2_status_t (AXIS2_CALL *
+ free_void_arg)(
+ void *storage_mgr,
+ const axis2_env_t *env);
+
+ struct sandesha2_transaction *(AXIS2_CALL *
+ get_transaction)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env);
+
+ void (AXIS2_CALL *
+ enlist_bean)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t *rm_bean);
+
+ sandesha2_create_seq_mgr_t *(AXIS2_CALL *
+ get_create_seq_mgr)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env);
+
+ sandesha2_next_msg_mgr_t *(AXIS2_CALL *
+ get_next_msg_mgr)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env);
+
+ sandesha2_sender_mgr_t *(AXIS2_CALL *
+ get_retrans_mgr)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env);
+
+ sandesha2_seq_property_mgr_t *(AXIS2_CALL *
+ get_seq_property_mgr)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env);
+
+ sandesha2_invoker_mgr_t *(AXIS2_CALL *
+ get_storage_map_mgr)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env);
+
+ axis2_status_t (AXIS2_CALL *
+ set_ctx)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
+
+ axis2_conf_ctx_t *(AXIS2_CALL *
+ get_ctx)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env);
+
+ axis2_status_t (AXIS2_CALL *
+ init)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
+
+ axis2_msg_ctx_t *(AXIS2_CALL *
+ retrieve_msg_ctx)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *key,
+ axis2_conf_ctx_t *conf_ctx);
+
+ axis2_status_t (AXIS2_CALL *
+ store_msg_ctx)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *key,
+ axis2_msg_ctx_t *msg_ctx);
+
+ axis2_status_t (AXIS2_CALL *
+ update_msg_ctx)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *key,
+ axis2_msg_ctx_t *msg_ctx);
+
+ axis2_status_t (AXIS2_CALL *
+ remove_msg_ctx)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *key);
+
+ axis2_status_t (AXIS2_CALL *
+ init_storage)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_module_desc_t *module_desc);
+
+ axiom_soap_envelope_t *(AXIS2_CALL *
+ retrieve_soap_envelope)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axis2_char_t *key);
+
+ axis2_status_t (AXIS2_CALL *
+ store_soap_envelope)(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ axiom_soap_envelope_t *soap_env,
+ axis2_char_t *key);
+};
+
+struct sandesha2_storage_mgr
+{
+ const sandesha2_storage_mgr_ops_t *ops;
+};
AXIS2_EXTERN sandesha2_storage_mgr_t* AXIS2_CALL
sandesha2_storage_mgr_create(
@@ -64,106 +187,106 @@
void *storage_mgr,
const axis2_env_t *env);
-sandesha2_storage_mgr_t *AXIS2_CALL
-sandesha2_storage_mgr_get_instance(
- sandesha2_storage_mgr_t *storage,
- const axis2_env_t *env,
- axis2_conf_ctx_t *conf_ctx);
-
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_free(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *envv);
-sandesha2_transaction_t *AXIS2_CALL
+struct sandesha2_transaction *AXIS2_CALL
sandesha2_storage_mgr_get_transaction(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env);
+void AXIS2_CALL
+sandesha2_storage_mgr_enlist_bean(
+ sandesha2_storage_mgr_t *storage_mgr,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t *rm_bean);
+
sandesha2_create_seq_mgr_t *AXIS2_CALL
sandesha2_storage_mgr_get_create_seq_mgr(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env);
sandesha2_next_msg_mgr_t *AXIS2_CALL
sandesha2_storage_mgr_get_next_msg_mgr(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env);
sandesha2_sender_mgr_t *AXIS2_CALL
sandesha2_storage_mgr_get_retrans_mgr(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env);
sandesha2_seq_property_mgr_t *AXIS2_CALL
sandesha2_storage_mgr_get_seq_property_mgr(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env);
sandesha2_invoker_mgr_t *AXIS2_CALL
sandesha2_storage_mgr_get_storage_map_mgr(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env);
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_set_ctx(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_conf_ctx_t *conf_ctx);
axis2_conf_ctx_t *AXIS2_CALL
sandesha2_storage_mgr_get_ctx(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env);
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_init(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_conf_ctx_t *conf_ctx);
axis2_msg_ctx_t *AXIS2_CALL
sandesha2_storage_mgr_retrieve_msg_ctx(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_char_t *key,
axis2_conf_ctx_t *conf_ctx);
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_store_msg_ctx(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_char_t *key,
axis2_msg_ctx_t *msg_ctx);
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_update_msg_ctx(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_char_t *key,
axis2_msg_ctx_t *msg_ctx);
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_remove_msg_ctx(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_char_t *key);
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_init_storage(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_module_desc_t *module_desc);
axiom_soap_envelope_t *AXIS2_CALL
sandesha2_storage_mgr_retrieve_soap_envelope(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axis2_char_t *key);
axis2_status_t AXIS2_CALL
sandesha2_storage_mgr_store_soap_envelope(
- sandesha2_storage_mgr_t *storage,
+ sandesha2_storage_mgr_t *storage_mgr,
const axis2_env_t *env,
axiom_soap_envelope_t *soap_env,
axis2_char_t *key);
Modified: webservices/sandesha/trunk/c/include/sandesha2_transaction.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_transaction.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_transaction.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_transaction.h Wed Dec 6 04:35:53 2006
@@ -35,6 +35,8 @@
typedef struct sandesha2_transaction sandesha2_transaction_t;
typedef struct sandesha2_transaction_ops sandesha2_transaction_ops_t;
+struct sandesha2_storage_mgr;
+struct sandesha2_rm_bean_t;
/** @defgroup sandesha2_transaction In Memory Transaction
* @ingroup sandesha2
@@ -48,19 +50,30 @@
* @return status code
*/
axis2_status_t (AXIS2_CALL *
- free) (
- void *transaction,
- const axis2_env_t *env);
+ free) (
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
+
+ axis2_bool_t (AXIS2_CALL *
+ is_active)(
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
- axis2_status_t (AXIS2_CALL *
- commit) (
- sandesha2_transaction_t *transaction,
- const axis2_env_t *env);
-
- axis2_status_t (AXIS2_CALL *
- rollback) (
- sandesha2_transaction_t *transaction,
- const axis2_env_t *env);
+ void (AXIS2_CALL *
+ commit) (
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
+
+ void (AXIS2_CALL *
+ rollback) (
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
+
+ void (AXIS2_CALL *
+ enlist)(
+ sandesha2_transaction_t *trans,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t *rm_bean);
};
struct sandesha2_transaction
@@ -68,20 +81,36 @@
sandesha2_transaction_ops_t *ops;
};
-AXIS2_EXTERN sandesha2_transaction_t * AXIS2_CALL
+AXIS2_EXTERN sandesha2_transaction_t* AXIS2_CALL
sandesha2_transaction_create(
- const axis2_env_t *env);
-
-#define SANDESHA2_TRANSACTION_FREE(transaction, env) \
- (((sandesha2_transaction_t *) transaction)->ops->free (transaction, env))
+ const axis2_env_t *env,
+ struct sandesha2_storage_mgr *storage_mgr);
-#define SANDESHA2_TRANSACTION_COMMIT(transaction, env) \
- (((sandesha2_transaction_t *) transaction)->ops->\
- commit (transaction, env))
-
-#define SANDESHA2_TRANSACTION_ROLLBACK(transaction, env) \
- (((sandesha2_transaction_t *) transaction)->ops->\
- rollback (transaction, env))
+axis2_status_t AXIS2_CALL
+sandesha2_transaction_free(
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
+
+axis2_bool_t AXIS2_CALL
+sandesha2_transaction_is_active(
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_transaction_commit(
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_transaction_rollback(
+ sandesha2_transaction_t *transaction,
+ const axis2_env_t *env);
+
+void AXIS2_CALL
+sandesha2_transaction_enlist(
+ sandesha2_transaction_t *trans,
+ const axis2_env_t *env,
+ struct sandesha2_rm_bean_t *rm_bean);
/** @} */
#ifdef __cplusplus
Modified: webservices/sandesha/trunk/c/include/sandesha2_utils.h
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/c/include/sandesha2_utils.h?view=diff&rev=483056&r1=483055&r2=483056
==============================================================================
--- webservices/sandesha/trunk/c/include/sandesha2_utils.h (original)
+++ webservices/sandesha/trunk/c/include/sandesha2_utils.h Wed Dec 6 04:35:53 2006
@@ -115,6 +115,11 @@
const axis2_env_t *env,
axis2_conf_ctx_t *conf_ctx,
axis2_char_t *seq_id);
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_utils_start_polling_mgr(
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
AXIS2_EXTERN axis2_char_t* AXIS2_CALL
sandesha2_utils_get_outgoing_internal_seq_id(
@@ -225,6 +230,21 @@
sandesha2_utils_is_anon_uri(
const axis2_env_t *env,
axis2_char_t *address);
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_utils_stop_invoker(
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_utils_stop_sender(
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
+
+AXIS2_EXTERN axis2_status_t AXIS2_CALL
+sandesha2_utils_stop_polling_mgr(
+ const axis2_env_t *env,
+ axis2_conf_ctx_t *conf_ctx);
/** @} */
#ifdef __cplusplus
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org