[rabbitmq-discuss] Testing Plugin / Internals Question

[Gavin M. Roy]

I’m working on a plugin that will let me trigger some internal behaviors in RabbitMQ from pika or any other RabbitMQ client for acceptance testing purposes.  In doing so, I’ve been trying to trace back how to get the connection pid() from the channel that is passed as the sender in the #delivery record passed into rabbit_exchange_type:route/2.

When I’m issuing rabbit_channel:info(pid()) for the sender, it seems to hang and I was hoping that was where I could get the connection pid.

Does anyone have any suggestions as to where I can get that info? Ultimately for this particular piece of functionality, I’m looking to trigger rabbit_reader:conserve_resources/3 to force a Connection.Blocked frame to be sent. Any alternative ways to trigger that from either the exchange or an interceptor would be helpful as well.

Thanks in advance,

Gavin


-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140416/6dd44684/attachment.html>