[rabbitmq-discuss] Ingress does not work for me and the RMQ goes down
Marek.Cermak at Honeywell.com
Fri Apr 5 13:18:18 BST 2013
yes, I use direct for both consumer and publisher. They run in one node, RMQ is in another.
> -----Original Message-----
> From: Simon MacMullen [mailto:simon at rabbitmq.com]
> Sent: 05 April, 2013 14:16
> To: Discussions about RabbitMQ
> Cc: Cermak, Marek
> Subject: Re: [rabbitmq-discuss] Ingress does not work for me and the RMQ goes
> Hi. amqp_channel:register_flow_handler/2 allows the client to know about
> channel.flow methods sent by the server. But in practice we haven't sent
> channel.flow for a long, long time (it doesn't really work very well).
> Instead we block the network socket. This works more immediately...
> assuming we are receiving messages over the network. However, if you are
> using the Erlang client in direct mode that won't happen - is that what
> you're doing?
> Cheers, Simon
> On 05/04/13 13:07, Cermak, Marek wrote:
> > Hello everybody,
> > I continue with stress testing on limited memory. This time I have
> > problem with RMQ going down without any warning after consuming a lot
> > of memory.
> > Producer asks for ingress on the channel
> > amqp_channel:register_flow_handler(Channel, self()),
> > and then it uses the channel for publishing messages. I.e. every 20
> > secs
> > 4 messages of 16 MB each to 2 different exchanges. After some time the
> > consumer starts to consume them (using one channel and prefetch of 4
> > msgs). Consumer is too slow to consume faster than messages are
> > produced. The broker warns once on the console and then it is killed:
> > 13:48:24.429 [warning] Undefined: memory resource limit alarm set on
> > node hare at xxx
> > Killed
> > shouldn't the producer be warned instead?
> > thanks
> > marek
> > _______________________________________________
> > rabbitmq-discuss mailing list
> > rabbitmq-discuss at lists.rabbitmq.com
> > https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
> Simon MacMullen
> RabbitMQ, VMware
More information about the rabbitmq-discuss