From 120bf4a4f6854592bd910334d4d0bd97c9f94974 Mon Sep 17 00:00:00 2001
From: Charles Chance <charles.chance@sipcentric.com>
Date: Thu, 13 Nov 2014 18:30:34 +0000
Subject: [PATCH] dmq: force to send replicated messages from configured server
 address - as reported on list by Victor Kustov

(cherry picked from commit 7b5f79f9f384bfe3c16c399184281ebe63bb7785)
---
 modules/dmq/dmq_funcs.c | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/modules/dmq/dmq_funcs.c b/modules/dmq/dmq_funcs.c
index 4b323c23929..7430193be4f 100644
--- a/modules/dmq/dmq_funcs.c
+++ b/modules/dmq/dmq_funcs.c
@@ -383,6 +383,7 @@ int cfg_dmq_bcast_message(struct sip_msg* msg, char* peer, char* body, char* con
 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) {