dmq: force to send replicated messages from configured server address…

… - as reported on list by Victor Kustov

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) {