[rabbitmq-discuss] Problem with publish confirms

[Ryan Brown]

I have an application that acts as, essentially, a rest wrapper around
rabbitmq. (There is obviously some special logic that makes it necessary to
build our own).

Some background: We have been using this application (current code
available at https://github.com/PearsonEducation/subpub) as an internal
pub/sub for several years now. It has now grown dramatically in importance
to our vision and we are beginning to get inundated with requests for
features and enhancements. One of those enhancements is to allow publishers
to specify with a header whether they want the application to require
confirmed publishing to rabbit. We had begun this process by checking for
the header value and passing down the chain. However, we are not currently
setting-up a channel that is set for publish confirms. Anyway, TMI...

The state I'm in now is that, on startup, we create connections to each of
our brokers. In this process we create a channel and save it in state. I
have now added logic to create a second channel on that connection that
sets:

 #'confirm.select_ok'{} = amqp_channel:call(ConfirmedChannel,
#'confirm.select'{}),

And saves it to state. Then on publish, I select which one to use based on
the values passed-down the stack from message intake. Set self() as the
confirm handler and respond with a wait so that up the stack I can initiate
a receive loop in the message intake which is not a gen_server. I have
debug messages throughout and it appears that everything is happening as
expected. I trace the message through the publish path. To being published
and passing the wait back up to the receiver. I also see where the
basic.ack is received and the publish_confirm acknowledgement passed all
the way up to the receive loop. However, then things go awry. I get the
attached dump.

My take-away, although likely I am wrong, is that somewhere, apparently in
amqp_balanced_publisher, a gen_server call is timing-out while waiting for
a response. But, I seem to be able to trace the responses through the whole
stack so I am thoroughly confused.

I realize this is vague and additional details/code are likely still
needed. Please let me know. I've spent way too much time on this already
and it's getting quite frustrating. And I know I am likely missing
something obvious but am finding supporting documentation for erlang
lacking. But I'm probably just looking in the right places.

Best regards,


Ryan
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140404/54e4575d/attachment.html>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: pub_confirm_dump
Type: application/octet-stream
Size: 41657 bytes
Desc: not available
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140404/54e4575d/attachment.obj>