Module: sip-router Branch: master Commit: 7b5f79f9f384bfe3c16c399184281ebe63bb7785 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=7b5f79f… Author: Charles Chance <charles.chance(a)sipcentric.com> Committer: Charles Chance <charles.chance(a)sipcentric.com> Date: Thu Nov 13 18:30:34 2014 +0000 dmq: force to send replicated messages from configured server address - as reported on list by Victor Kustov --- modules/dmq/dmq_funcs.c | 7 +++++++ 1 files changed, 7 insertions(+), 0 deletions(-) diff --git a/modules/dmq/dmq_funcs.c b/modules/dmq/dmq_funcs.c index 4b323c2..7430193 100644 --- a/modules/dmq/dmq_funcs.c +++ b/modules/dmq/dmq_funcs.c @@ -383,6 +383,7 @@ error: int cfg_dmq_t_replicate(struct sip_msg* msg, char* s) { dmq_node_t* node; + struct socket_info* sock; int i = 0; /* avoid loops - do not replicate if message has come from another node @@ -394,6 +395,12 @@ int cfg_dmq_t_replicate(struct sip_msg* msg, char* s) return -1; } + /* TODO - backup/restore original send socket */ + sock = lookup_local_socket(&dmq_server_socket); + if (sock) { + set_force_socket(msg, sock); + } + lock_get(&node_list->lock); node = node_list->nodes; while(node) {