00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017 #ifndef SANDESHA2_SENDER_WORKER_H
00018 #define SANDESHA2_SENDER_WORKER_H
00019
00025 #include <axutil_allocator.h>
00026 #include <axutil_env.h>
00027 #include <axutil_error.h>
00028 #include <axutil_string.h>
00029 #include <axutil_utils.h>
00030 #include <axis2_conf_ctx.h>
00031
00032 #ifdef __cplusplus
00033 extern "C"
00034 {
00035 #endif
00036
00037 typedef struct sandesha2_sender_worker_t sandesha2_sender_worker_t;
00038
00039 AXIS2_EXTERN sandesha2_sender_worker_t* AXIS2_CALL
00040 sandesha2_sender_worker_create(
00041 const axutil_env_t *env,
00042 axis2_conf_ctx_t *conf_ctx,
00043 axis2_char_t *msg_id);
00044
00045 AXIS2_EXTERN sandesha2_sender_worker_t* AXIS2_CALL
00046 sandesha2_sender_worker_create_with_msg_ctx(
00047 const axutil_env_t *env,
00048 axis2_conf_ctx_t *conf_ctx,
00049 axis2_char_t *msg_id,
00050 axis2_msg_ctx_t *msg_ctx);
00051
00059 AXIS2_EXTERN axis2_status_t AXIS2_CALL
00060 sandesha2_sender_worker_free_void_arg(
00061 void *sender_worker,
00062 const axutil_env_t *env);
00063
00064 axis2_status_t AXIS2_CALL
00065 sandesha2_sender_worker_free(
00066 sandesha2_sender_worker_t *sender_worker,
00067 const axutil_env_t *env);
00068
00069 axis2_status_t AXIS2_CALL
00070 sandesha2_sender_worker_stop_sender_worker_for_seq(
00071 sandesha2_sender_worker_t *sender_worker,
00072 const axutil_env_t *env,
00073 axis2_char_t *seq_id);
00074
00075 axis2_status_t AXIS2_CALL
00076 sandesha2_sender_worker_stop_sending (
00077 sandesha2_sender_worker_t *sender_worker,
00078 const axutil_env_t *env);
00079
00080 axis2_bool_t AXIS2_CALL
00081 sandesha2_sender_worker_is_sender_worker_started(
00082 sandesha2_sender_worker_t *sender_worker,
00083 const axutil_env_t *env);
00084
00085 axis2_status_t AXIS2_CALL
00086 sandesha2_sender_worker_run_for_seq
00087 (sandesha2_sender_worker_t *sender_worker,
00088 const axutil_env_t *env,
00089 axis2_conf_ctx_t *conf_ctx,
00090 axis2_char_t *seq_id);
00091
00092 axis2_status_t AXIS2_CALL
00093 sandesha2_sender_worker_run (
00094 sandesha2_sender_worker_t *sender_worker,
00095 const axutil_env_t *env,
00096 const axis2_bool_t persistent_msg_ctx);
00097
00098 void sandesha2_sender_worker_set_transport_out(
00099 sandesha2_sender_worker_t *sender_worker,
00100 const axutil_env_t *env,
00101 axis2_transport_out_desc_t *transport_out);
00102
00103 axis2_status_t AXIS2_CALL
00104 sandesha2_sender_worker_get_status (
00105 sandesha2_sender_worker_t *sender_worker,
00106 const axutil_env_t *env);
00107
00108
00110 #ifdef __cplusplus
00111 }
00112 #endif
00113 #endif