From d93b660bb607ada0d00777dda37162a99b80656b Mon Sep 17 00:00:00 2001 From: lazedo Date: Thu, 4 Sep 2014 22:28:07 +0100 Subject: [PATCH] KAZOO-2780 'no_ack' : 0, 'wait_for_consumer_ack' : 1 --- kamailio/default.cfg | 16 ++++++++++++++-- 1 file changed, 14 insertions(+), 2 deletions(-) diff --git a/kamailio/default.cfg b/kamailio/default.cfg index 1cc47c2..d3ca128 100644 --- a/kamailio/default.cfg +++ b/kamailio/default.cfg @@ -606,8 +606,20 @@ event_route[kazoo:mod-init] ### use this simple form of binding a listener ### kazoo_subscribe("dialoginfo", "direct", "BLF-QUEUE-MY_HOSTNAME", "BLF-MY_HOSTNAME"); ### -### or unleash the power of rabbit to kazoo-blf - $var(payload) = "{ 'exchange' : 'dialoginfo' , 'type' : 'direct', 'queue' : 'BLF-QUEUE-MY_HOSTNAME', 'routing' : 'BLF-MY_HOSTNAME', 'auto_delete' : 0, 'durable' : 1, 'no_ack' : 0 }"; +### or unleash the power of rabbit to kazoo-blf +### +### 'no_ack' : 1 => needs ack, +### 'wait_for_consumer_ack' +### : 1 => when it receives, it processses on the AMQP Worker ad after that it confirms +### : 0 => when it receives, it acks then processes in the AMQP Worker +### only works if no_ack : 0 +### +### Rabbit Policy for ha-mode +### pattern : ^BLF +### definition : ha-mode: all +### +### + $var(payload) = "{ 'exchange' : 'dialoginfo' , 'type' : 'direct', 'queue' : 'BLF-QUEUE-MY_HOSTNAME', 'routing' : 'BLF-MY_HOSTNAME', 'auto_delete' : 0, 'durable' : 1, 'no_ack' : 0, 'wait_for_consumer_ack' : 1 }"; xlog("L_INFO","SUBSCRIBE $var(payload)"); kazoo_subscribe("$var(payload)");