[OpenSIPS-Users] RabbitMQ Timer Route Not Working
Bogdan-Andrei Iancu
bogdan at opensips.org
Thu Jun 5 17:32:51 CEST 2014
So it seems the subscribing works fine. You can check that via the
"subscribers_list" MI command (see
http://www.opensips.org/Documentation/Interface-CoreMI-1-11#toc18).
The problem is when the actual event is generated - it looks like it
cannot be delivered via the rabbitmq driver. What you do is you move the
IP of the HAproxy on a different machine ?
Regards,
Bogdan-Andrei Iancu
OpenSIPS Founder and Developer
http://www.opensips-solutions.com
On 05.06.2014 17:31, Kneeoh wrote:
> Jun 5 14:19:24 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:24 opensips /usr/local/sbin/opensips[19027]: Subscribing to MISSED Event
> Jun 5 14:19:24 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:24 opensips /usr/local/sbin/opensips[19027]: Subscribing to CHANNEL Event
> Jun 5 14:19:24 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/limits
> Jun 5 14:19:24 opensips /usr/local/sbin/opensips[19027]: Subscribing to CPS Event
> Jun 5 14:19:24 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/limits
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19020]: Enforcing Limits
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19020]: Account Channel Limit OK. Channels Up: 0 Channel Limit: 1
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19020]: Call Rejected due to Account CPS Limit. CPS Limit: 0
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: Subscribing to CDR Event
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: Subscribing to ACC Event
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: Subscribing to MISSED Event
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: Subscribing to CHANNEL Event
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/limits
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: Subscribing to CPS Event
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/limits
> Jun 5 14:19:29 opensips /usr/local/sbin/opensips[19021]: ACK - Attempting to match dialog
> Jun 5 14:19:33 opensips /usr/local/sbin/opensips[19027]: Subscribing to CDR Event
> Jun 5 14:19:33 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:33 opensips /usr/local/sbin/opensips[19027]: Subscribing to ACC Event
> Jun 5 14:19:33 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:33 opensips /usr/local/sbin/opensips[19027]: Subscribing to MISSED Event
> Jun 5 14:19:33 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:19:33 opensips /usr/local/sbin/opensips[19027]: Subscribing to CHANNEL Event
>
>
>
> The above works and sends an event to RabbitMQ via 192.168.2.30 (the virtual IP of haproxy)
>
>
>
> FAIL OVER HAPROXY - IP moves to backup HAProxy identical to the first Opensips is none the wiser.
>
> NEW CALL
>
>
>
> Jun 5 14:20:17 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/limits
> Jun 5 14:20:20 opensips /usr/local/sbin/opensips[19020]: Enforcing Limits
> Jun 5 14:20:20 opensips /usr/local/sbin/opensips[19020]: Account Channel Limit OK. Channels Up: 0 Channel Limit: 1
> Jun 5 14:20:20 opensips /usr/local/sbin/opensips[19020]: Call Rejected due to Account CPS Limit. CPS Limit: 0
> Jun 5 14:20:20 opensips /usr/local/sbin/opensips[19012]: ERROR:event_rabbitmq:rmq_process: cannot send message
> Jun 5 14:20:20 opensips /usr/local/sbin/opensips[19012]: ERROR:event_rabbitmq:rmq_process: cannot send message
> Jun 5 14:20:20 opensips /usr/local/sbin/opensips[19012]: ERROR:event_rabbitmq:rmq_process: cannot send message
> Jun 5 14:20:20 opensips /usr/local/sbin/opensips[19021]: ACK - Attempting to match dialog
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: Subscribing to CDR Event
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: Subscribing to ACC Event
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: Subscribing to MISSED Event
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/cdr1
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: Subscribing to CHANNEL Event
> Jun 5 14:20:21 opensips /usr/local/sbin/opensips[19027]: DBG:event_rabbitmq:rmq_match: socket matched: rabbitmq at 192.168.2.30:5672/limits
>
> FAILs to send event to RabbitMQ
>
>
>
> On Thursday, June 5, 2014 7:57 AM, Bogdan-Andrei Iancu <bogdan at opensips.org> wrote:
> Hi,
>
> Try to get some debug logs from that route. Do:
>
> timer_route[event_subscribe, 4] {
> setdebug(4);
> xlog("Subscribing from timer route....\n");
> if (!subscribe_event("E_ACC_CDR", "rabbitmq:cdr:rabbit at 192.168.2.30/cdr1", 5)) {
> xlog("L_INFO", "Can't connect to RabbitMQ \n");
> }
> setdebug();
> }
>
> Regards,
>
> Bogdan-Andrei Iancu
> OpenSIPS Founder and Developer
> http://www.opensips-solutions.com
>
>
>
>
> On 02.06.2014 17:55, Kneeoh wrote:
>> After following the example here: http://www.opensips.org/Documentation/Tutorials-EventInterface
>>
>> Shouldn't this resubscribe every 4 seconds and expire in 5 (i.e. never)? in my script it's not subscribing to rabbit at all. I'm running version: Server:: OpenSIPS (1.10.1-notls (x86_64/linux))
>>
>> timer_route[event_subscribe, 4] {
>> if (!subscribe_event("E_ACC_CDR", "rabbitmq:cdr:rabbit at 192.168.2.30/cdr1", 5)) {
>> xlog("L_INFO", "Can't connect to RabbitMQ \n");
>> }
>> }
>>
>> root at osips:/var/log# tcpdump -s0 -ni eth1 host 192.168.2.30
>> tcpdump: verbose output suppressed, use -v or -vv for full protocol decode
>> listening on eth1, link-type EN10MB (Ethernet), capture size 65535 bytes
>> ^C
>> 0 packets captured
>> 0 packets received by filter
>> 0 packets dropped by kernel
>>
>>
>> _______________________________________________
>> Users mailing list
>> Users at lists.opensips.org
>> http://lists.opensips.org/cgi-bin/mailman/listinfo/users
More information about the Users
mailing list