|
|
@ -606,8 +606,20 @@ event_route[kazoo:mod-init] |
|
|
### use this simple form of binding a listener |
|
|
### use this simple form of binding a listener |
|
|
### kazoo_subscribe("dialoginfo", "direct", "BLF-QUEUE-MY_HOSTNAME", "BLF-MY_HOSTNAME"); |
|
|
### 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)"); |
|
|
xlog("L_INFO","SUBSCRIBE $var(payload)"); |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
kazoo_subscribe("$var(payload)"); |
|
|
|
|
|
|
|
|
|