kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-03-06 10:26:41 +00:00
Code Issues Projects Releases Wiki Activity

fix reconnection for aux channels

Browse Source
This commit is contained in:
Aleksei Khabuliak 2023-01-07 19:49:44 -08:00
parent 63bd218f98
commit 3aadc42e59
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/mod/event_handlers/mod_amqp/mod_amqp_xml_handler.c
View File

@ -504,6 +504,10 @@ void *SWITCH_THREAD_FUNC mod_amqp_xml_handler_thread(switch_thread_t *thread, vo
mod_amqp_aux_connection_t *conn_aux = NULL, *conn_next = NULL; mod_amqp_aux_connection_t *conn_aux = NULL, *conn_next = NULL;
amqp_boolean_t passive = 0; amqp_boolean_t passive = 0;
amqp_boolean_t durable = 1; amqp_boolean_t durable = 1;
// init first temp connection (for outgoing msgs)
if (!profile->conn_aux) {
profile->conn_aux = switch_core_alloc(profile->pool, sizeof(mod_amqp_aux_connection_t));
}
while (profile->running) { while (profile->running) {
if (!profile->conn_active) { if (!profile->conn_active) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Amqp no connection- reconnecting...\n"); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Amqp no connection- reconnecting...\n");
@ -511,10 +515,6 @@ void *SWITCH_THREAD_FUNC mod_amqp_xml_handler_thread(switch_thread_t *thread, vo
status = mod_amqp_connection_open(profile->conn_root, &(profile->conn_active), profile->name, status = mod_amqp_connection_open(profile->conn_root, &(profile->conn_active), profile->name,
profile->custom_attr); profile->custom_attr);
if (status == SWITCH_STATUS_SUCCESS) { if (status == SWITCH_STATUS_SUCCESS) {
// init first temp connection (for outgoing msgs)
if (!profile->conn_aux) {
profile->conn_aux = switch_core_alloc(profile->pool, sizeof(mod_amqp_aux_connection_t));
}
switch_mutex_lock(profile->mutex); switch_mutex_lock(profile->mutex);
for (conn_aux = profile->conn_aux; conn_aux; conn_aux = conn_next) { for (conn_aux = profile->conn_aux; conn_aux; conn_aux = conn_next) {
mod_amqp_aux_connection_open(profile->conn_active, &(conn_aux), profile->name, profile->custom_attr); mod_amqp_aux_connection_open(profile->conn_active, &(conn_aux), profile->name, profile->custom_attr);