I&#39;ve just swapped out the whole amqp_client infrastructure in my erlang application to the latest release. It looks like there were significant changes to the infrastructure but the api remains almost identical (the network vs direct connection being the only exception I&#39;ve found).  But now I&#39;m getting an error in code that used to work about my subscription.  My code looks like this:<div>
<br></div><div><br></div><div>%% Queue is a binary name, Listener is a PID and State is a dictionary containing various things including the channel PID</div><div><div>subscribe(Queue,Listener,State) -&gt;</div><div>    Sub = #&#39;basic.consume&#39;{queue = Queue},</div>
<div>    #&#39;basic.consume_ok&#39;{consumer_tag = Tag} = amqp_channel:subscribe(State:fetch(amqp_channel_pid), Sub, Listener),</div><div>    {ok, Tag}.</div></div><div><br></div><div><br></div><div>This worked with the previous version of the library and I don&#39;t see any difference in the docs (<a href="http://www.rabbitmq.com/erlang-client-user-guide.html">http://www.rabbitmq.com/erlang-client-user-guide.html</a>) now it produces the following error:</div>
<div><br></div><div><div> {{function_clause,</div><div>                      [{amqp_selective_consumer,handle_consume_ok,</div><div>                           [{&#39;basic.consume_ok&#39;,</div><div>                                &lt;&lt;&quot;amq.ctag-yC9CxaknYwPrAYj5hCChPQ==&quot;&gt;&gt;},</div>
<div>                            {&#39;basic.consume&#39;,0,&lt;&lt;&quot;harbinger-dm-hipaa&quot;&gt;&gt;,&lt;&lt;&gt;&gt;,</div><div>                                false,false,false,false,[]},</div><div>                            {state,</div>
<div>                                {dict,0,16,16,8,80,48,</div><div>                                    {[],[],[],[],[],[],[],[],[],[],[],[],[],</div><div>                                     [],[],[]},</div><div>                                    {{[],[],[],[],[],[],[],[],[],[],[],[],[],</div>
<div>                                      [],[],[]}}},</div><div>                                hipaa,</div><div>                                {dict,0,16,16,8,80,48,</div><div>                                    {[],[],[],[],[],[],[],[],[],[],[],[],[],</div>
<div>                                     [],[],[]},</div><div>                                    {{[],[],[],[],[],[],[],[],[],[],[],[],[],</div><div>                                      [],[],[]}}},</div><div>                                none}]},</div>
<div>                       {amqp_gen_consumer,handle_call,3},</div><div>                       {gen_server2,handle_msg,2},</div><div>                       {proc_lib,init_p_do_apply,3}]},</div><div>                  {gen_server2,call,</div>
<div>                      [&lt;0.181.0&gt;,</div><div>                       {consumer_call,</div><div>                           {&#39;basic.consume_ok&#39;,</div><div>                               &lt;&lt;&quot;amq.ctag-yC9CxaknYwPrAYj5hCChPQ==&quot;&gt;&gt;},</div>
<div>                           {&#39;basic.consume&#39;,0,&lt;&lt;&quot;harbinger-dm-hipaa&quot;&gt;&gt;,&lt;&lt;&gt;&gt;,</div><div>                               false,false,false,false,[]}},</div><div>                       infinity]}}</div>
</div><div><br></div><div>There is a clause in the new docs that explains the difference between the selective consumer and the direct consumer. Based on that description it seems like everything used to be a direct consumer and that&#39;s what I should be using, but I don&#39;t see any docs on how to use it. I explored the rabbit headers and couldn&#39;t find anything that would let me select it. The only mention of it I found was when selective consumer is set as the default.</div>
<div><br></div><div>Thanks,</div><div>-Max</div>