<div dir="ltr">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).<div><br></div><div>Some background: We have been using this application (current code available at <a href="https://github.com/PearsonEducation/subpub">https://github.com/PearsonEducation/subpub</a>) 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...</div>
<div><br></div><div>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:</div>
<div><br></div><div>







<p class=""> #'confirm.select_ok'{} = amqp_channel:call(ConfirmedChannel, #'confirm.select'{}),</p><p class="">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.</p>
<p class="">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.</p>
<p class="">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.</p>
<p class="">Best regards,</p><p class=""><br></p><p class="">Ryan</p></div></div>