Differences

This shows you the differences between two versions of the page.

Link to this comparison view

irc:1468620000 [2017/05/27 13:44] (current)
Line 1: Line 1:
 +[01:05:23] *** ChanServ sets mode: +o temporalfox
 +
 +[10:58:22] *** ChanServ sets mode: +o temporalfox
 +
 +[14:24:00] *** ChanServ sets mode: +o temporalfox
 +
 +[14:58:55] <​whitenexx>​ Hi together, does somebody know how to buffer messages from rabbitmq within vertx? My problem is that my rabbitmq to vertx eventbus mapper consumers all rabbitmq messages. I would like to only consume/​buffer 20 messages instead of all
 +
 +[16:17:53] <​Sticky_>​ whitenexx: afaik at the moment vertx still does not have a concept of buffering/​backlog on the eventbus (I dont know anything about rabbit specifically). But look at the rx stuff, there is a lot of stuff in there for controlling the backlog/​rate etc of emmiting events
 +
 +[18:45:58] <​whitenexx>​ Sticky_: is it possible to get the number of waiting messages on the event bus?
 +
 +[18:46:19] <​whitenexx>​ for a specific address
 +
 +[19:12:53] <​Sticky_>​ whitenexx: well the event buss has no backlog, so there cannot be any waiting messages
 +
 +[19:14:28] <​whitenexx>​ ok thank you Sticky_, so my rabbit messages have to be buffered elsewhere (seems like the rabbit client is doing this)
 +
 +[19:14:54] <​whitenexx>​ i already found a method called "​basicQos()"​
 +
 +[19:15:12] <​whitenexx>​ i'll test it, maybe i can rate limit the messages with that