[sr-dev] git:master: dmq: force to send replicated messages from configured server address - as reported on list by Victor Kustov

[Charles Chance]

Module: sip-router
Branch: master
Commit: 7b5f79f9f384bfe3c16c399184281ebe63bb7785
URL:    http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=7b5f79f9f384bfe3c16c399184281ebe63bb7785

Author: Charles Chance <charles.chance at sipcentric.com>
Committer: Charles Chance <charles.chance at 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) {