[OpenSIPS-Users] RabbitMQ Timer Route Not Working

[Kneeoh]

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

>