00001 #ifndef DMQ_FUNCS_H
00002 #define DMQ_FUNCS_H
00003
00004 #include "../../str.h"
00005 #include "../../modules/tm/dlg.h"
00006 #include "../../modules/tm/tm_load.h"
00007 #include "../../config.h"
00008 #include "peer.h"
00009 #include "worker.h"
00010 #include "dmqnode.h"
00011
00012 void ping_servers(unsigned int ticks,void *param);
00013
00014 typedef struct dmq_resp_cback {
00015 int (*f)(struct sip_msg* msg, int code, dmq_node_t* node, void* param);
00016 void* param;
00017 } dmq_resp_cback_t;
00018
00019 typedef struct dmq_cback_param {
00020 dmq_resp_cback_t resp_cback;
00021 dmq_node_t* node;
00022 } dmq_cback_param_t;
00023
00024 int cfg_dmq_send_message(struct sip_msg* msg, char* peer, char* to, char* body);
00025 dmq_peer_t* register_dmq_peer(dmq_peer_t* peer);
00026 int dmq_send_message(dmq_peer_t* peer, str* body, dmq_node_t* node, dmq_resp_cback_t* resp_cback, int max_forwards);
00027 int bcast_dmq_message(dmq_peer_t* peer, str* body, dmq_node_t* except, dmq_resp_cback_t* resp_cback, int max_forwards);
00028
00029 #endif
00030
