Hi all,<div><br></div><div>I am now getting the following errors when using RabbitMQ with Python Celery and Django Celery..</div><div><br></div><div>The below error messages doesn&#39;t mean much to be sadly.. Could anyone shed some light on what the below actually means??</div>
<div><br></div><div>Cheers</div><div><br></div><div>Cal</div><div><br></div><div><div>==&gt; /var/log/rabbitmq/rabbit@mail01.log &lt;==</div><div><br></div><div>=WARNING REPORT==== 19-Aug-2010::01:13:31 ===</div><div>exception on TCP connection &lt;0.2829.0&gt; from <a href="http://10.1.3.1:54996">10.1.3.1:54996</a></div>
<div>connection_closed_abruptly</div><div><br></div><div>=INFO REPORT==== 19-Aug-2010::01:13:31 ===</div><div>closing TCP connection &lt;0.2829.0&gt; from <a href="http://10.1.3.1:54996">10.1.3.1:54996</a></div><div><br></div>
<div>=INFO REPORT==== 19-Aug-2010::01:13:32 ===</div><div>accepted TCP connection on <a href="http://0.0.0.0:5672">0.0.0.0:5672</a> from <a href="http://10.1.3.1:44483">10.1.3.1:44483</a></div><div><br></div><div>=INFO REPORT==== 19-Aug-2010::01:13:32 ===</div>
<div>starting TCP connection &lt;0.2923.0&gt; from <a href="http://10.1.3.1:44483">10.1.3.1:44483</a></div><div><br></div><div>=INFO REPORT==== 19-Aug-2010::01:13:32 ===</div><div>accepted TCP connection on <a href="http://0.0.0.0:5672">0.0.0.0:5672</a> from <a href="http://10.1.3.1:44484">10.1.3.1:44484</a></div>
<div><br></div><div>=INFO REPORT==== 19-Aug-2010::01:13:32 ===</div><div>starting TCP connection &lt;0.2925.0&gt; from <a href="http://10.1.3.1:44484">10.1.3.1:44484</a></div><div><br></div><div>=ERROR REPORT==== 19-Aug-2010::01:13:32 ===</div>
<div>** Generic server &lt;0.2936.0&gt; terminating</div><div>** Last message in was {&#39;$gen_cast&#39;,</div><div>                           {method,</div><div>                               {&#39;basic.publish&#39;,0,&lt;&lt;&quot;tasks&quot;&gt;&gt;,</div>
<div>                                   &lt;&lt;&quot;bluemail.cache.updatecampaignstatus&quot;&gt;&gt;,</div><div>                                   false,false},</div><div>                               {content,60,none,</div>
<div>                                   &lt;&lt;208,0,30,97,112,112,108,105,99,97,116,105,</div><div>                                     111,110,47,120,45,112,121,116,104,111,110,</div><div>                                     45,115,101,114,105,97,108,105,122,101,6,</div>
<div>                                     98,105,110,97,114,121,2&gt;&gt;,</div><div>                                   rabbit_framing_amqp_0_8,</div><div>                                   [&lt;&lt;&quot;(dp1\nS&#39;retries&#39;\np2\nI0\nsS&#39;task&#39;\np3\nS&#39;webapp.bluemail.tasks.UpdateCampaignStatus&#39;\np4\nsS&#39;args&#39;\np5\n(lp6\nsS&#39;eta&#39;\np7\nNsS&#39;kwargs&#39;\np8\n(dp9\nsS&#39;id&#39;\np10\nS&#39;c49f1e35-a042-43ba-9316-3e99e27a6bf7&#39;\np11\ns.&quot;&gt;&gt;]}}}</div>
<div>** When Server state == {ch,running,1,&lt;0.2925.0&gt;,&lt;0.2934.0&gt;,undefined,none,</div><div>                            {sets,0,16,16,8,80,48,</div><div>                                  {[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div>
<div>                                   [],[]},</div><div>                                  {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div><div>                                    [],[]}}},</div><div>                            1,</div>
<div>                            {[],[]},</div><div>                            {[],[]},</div><div>                            &lt;&lt;&quot;simplicitymedialtd&quot;&gt;&gt;,&lt;&lt;&quot;bluemail_dev&quot;&gt;&gt;,&lt;&lt;&gt;&gt;,</div>
<div>                            {dict,0,16,16,8,80,48,</div><div>                                  {[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div><div>                                   [],[]},</div><div>                                  {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div>
<div>                                    [],[]}}},</div><div>                            {dict,0,16,16,8,80,48,</div><div>                                  {[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div><div>                                   [],[]},</div>
<div>                                  {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div><div>                                    [],[]}}},</div><div>                            &lt;0.2926.0&gt;,</div><div>                            {state,none,undefined}}</div>
<div>** Reason for termination ==</div><div>** {{undef,[{re,split,</div><div>                [&lt;&lt;&quot;bluemail.cache.#&quot;&gt;&gt;,&quot;\\.&quot;,[{return,list}]]},</div><div>            {rabbit_exchange_type_topic,topic_matches,2},</div>
<div>            {rabbit_router,&#39;-match_bindings/2-fun-1-&#39;,10},</div><div>            {qlc,collect,1},</div><div>            {qlc,eval,2},</div><div>            {mnesia_tm,non_transaction,5},</div><div>            {rabbit_router,match_bindings,2},</div>
<div>            {rabbit_exchange_type_topic,publish,2}]},</div><div>    [{mnesia_tm,non_transaction,5},</div><div>     {rabbit_router,match_bindings,2},</div><div>     {rabbit_exchange_type_topic,publish,2},</div><div>     {rabbit_exchange,publish,3},</div>
<div>     {rabbit_channel,handle_method,3},</div><div>     {rabbit_channel,handle_cast,2},</div><div>     {gen_server2,handle_msg,7},</div><div>     {proc_lib,init_p,5}]}</div><div><br></div><div>=ERROR REPORT==== 19-Aug-2010::01:13:32 ===</div>
<div>connection &lt;0.2925.0&gt; (running), channel 1 - error:</div><div>{{undef,[{re,split,</div><div>             [&lt;&lt;&quot;bluemail.cache.#&quot;&gt;&gt;,&quot;\\.&quot;,[{return,list}]]},</div><div>         {rabbit_exchange_type_topic,topic_matches,2},</div>
<div>         {rabbit_router,&#39;-match_bindings/2-fun-1-&#39;,10},</div><div>         {qlc,collect,1},</div><div>         {qlc,eval,2},</div><div>         {mnesia_tm,non_transaction,5},</div><div>         {rabbit_router,match_bindings,2},</div>
<div>         {rabbit_exchange_type_topic,publish,2}]},</div><div> [{mnesia_tm,non_transaction,5},</div><div>  {rabbit_router,match_bindings,2},</div><div>  {rabbit_exchange_type_topic,publish,2},</div><div>  {rabbit_exchange,publish,3},</div>
<div>  {rabbit_channel,handle_method,3},</div><div>  {rabbit_channel,handle_cast,2},</div><div>  {gen_server2,handle_msg,7},</div><div>  {proc_lib,init_p,5}]}</div><div><br></div><div>=WARNING REPORT==== 19-Aug-2010::01:13:32 ===</div>
<div>Non-AMQP exit reason &#39;{{undef,[{re,split,</div><div>                                   [&lt;&lt;&quot;bluemail.cache.#&quot;&gt;&gt;,&quot;\\.&quot;,</div><div>                                    [{return,list}]]},</div>
<div>                               {rabbit_exchange_type_topic,topic_matches,2},</div><div>                               {rabbit_router,&#39;-match_bindings/2-fun-1-&#39;,10},</div><div>                               {qlc,collect,1},</div>
<div>                               {qlc,eval,2},</div><div>                               {mnesia_tm,non_transaction,5},</div><div>                               {rabbit_router,match_bindings,2},</div><div>                               {rabbit_exchange_type_topic,publish,2}]},</div>
<div>                       [{mnesia_tm,non_transaction,5},</div><div>                        {rabbit_router,match_bindings,2},</div><div>                        {rabbit_exchange_type_topic,publish,2},</div><div>                        {rabbit_exchange,publish,3},</div>
<div>                        {rabbit_channel,handle_method,3},</div><div>                        {rabbit_channel,handle_cast,2},</div><div>                        {gen_server2,handle_msg,7},</div><div>                        {proc_lib,init_p,5}]}&#39;</div>
<div><br></div><div>=INFO REPORT==== 19-Aug-2010::01:13:32 ===</div><div>closing TCP connection &lt;0.2925.0&gt; from <a href="http://10.1.3.1:44484">10.1.3.1:44484</a></div><div><br></div><div>==&gt; /var/log/rabbitmq/rabbit@mail01-sasl.log &lt;==</div>
<div><br></div><div>=CRASH REPORT==== 19-Aug-2010::01:13:32 ===</div><div>  crasher:</div><div>    pid: &lt;0.2936.0&gt;</div><div>    registered_name: []</div><div>    exception exit: {{undef,[{re,split,</div><div>                                 [&lt;&lt;&quot;bluemail.cache.#&quot;&gt;&gt;,&quot;\\.&quot;,</div>
<div>                                  [{return,list}]]},</div><div>                             {rabbit_exchange_type_topic,topic_matches,2},</div><div>                             {rabbit_router,&#39;-match_bindings/2-fun-1-&#39;,10},</div>
<div>                             {qlc,collect,1},</div><div>                             {qlc,eval,2},</div><div>                             {mnesia_tm,non_transaction,5},</div><div>                             {rabbit_router,match_bindings,2},</div>
<div>                             {rabbit_exchange_type_topic,publish,2}]},</div><div>                     [{mnesia_tm,non_transaction,5},</div><div>                      {rabbit_router,match_bindings,2},</div><div>                      {rabbit_exchange_type_topic,publish,2},</div>
<div>                      {rabbit_exchange,publish,3},</div><div>                      {rabbit_channel,handle_method,3},</div><div>                      {rabbit_channel,handle_cast,2},</div><div>                      {gen_server2,handle_msg,7},</div>
<div>                      {proc_lib,init_p,5}]}</div><div>      in function  gen_server2:terminate/6</div><div>    initial call: gen:init_it(gen_server2,&lt;0.2935.0&gt;,&lt;0.2935.0&gt;,</div><div>                              rabbit_channel,</div>
<div>                              [1,&lt;0.2925.0&gt;,&lt;0.2934.0&gt;,</div><div>                               &lt;&lt;&quot;simplicitymedialtd&quot;&gt;&gt;,&lt;&lt;&quot;bluemail_dev&quot;&gt;&gt;,</div><div>                               &lt;0.2926.0&gt;],</div>
<div>                              [])</div><div>    ancestors: [&lt;0.2935.0&gt;]</div><div>    messages: []</div><div>    links: [&lt;0.2935.0&gt;]</div><div>    dictionary: [{permission_cache,</div><div>                      [{{resource,&lt;&lt;&quot;bluemail_dev&quot;&gt;&gt;,exchange,&lt;&lt;&quot;tasks&quot;&gt;&gt;},</div>
<div>                        write},</div><div>                       {{resource,&lt;&lt;&quot;bluemail_dev&quot;&gt;&gt;,exchange,&lt;&lt;&quot;tasks&quot;&gt;&gt;},</div><div>                        configure}]},</div><div>
                  {guid,{{0,&lt;0.2936.0&gt;},0}}]</div><div>    trap_exit: true</div><div>    status: running</div><div>    heap_size: 610</div><div>    stack_size: 23</div><div>    reductions: 2649</div><div>  neighbours:</div>
<div><br></div><div>==&gt; /var/log/rabbitmq/rabbit@mail01.log &lt;==</div><div><br></div><div>=INFO REPORT==== 19-Aug-2010::01:13:38 ===</div><div>closing TCP connection &lt;0.2923.0&gt; from <a href="http://10.1.3.1:44483">10.1.3.1:44483</a></div>
<div>^C</div><div><br></div><div> <a href="mailto:root@mail01.dmemedialtd.com">root@mail01.dmemedialtd.com</a> [~/rabbitmq-server/scripts] &gt;</div><div><br></div><br><div class="gmail_quote">On Wed, Aug 18, 2010 at 11:39 PM, Matthew Sackman <span dir="ltr">&lt;<a href="mailto:matthew@rabbitmq.com">matthew@rabbitmq.com</a>&gt;</span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">Hi Cal,<br>
<div class="im"><br>
&gt; On Wed, Aug 18, 2010 at 10:44 PM, Cal Leeming [Simplicity Media Ltd] &lt;<br>
&gt; <a href="mailto:cal.leeming@simplicitymedialtd.co.uk">cal.leeming@simplicitymedialtd.co.uk</a>&gt; wrote:<br>
</div><div class="im">&gt; &gt; This might be a little question but, if RabbitMQ runs out of memory, and I<br>
&gt; &gt; am unable to open a new channel, how would one then consume off the queue,<br>
&gt; &gt; if one isn&#39;t able to open a channel to do so? Or is this something which has<br>
&gt; &gt; been solved with the new persister?<br>
<br>
</div>The &quot;new persister&quot; is the solution to this problem and has recently<br>
been merged into the default branch (a couple of weeks ago) which is why<br>
you&#39;re now seeing that this isn&#39;t so much of a problem.<br>
<br>
Basically, the &quot;new persister&quot; allows paging of messages so Rabbit<br>
should never run out of memory for very long - it should always (well,<br>
nearly always) be able to free up some memory by writing messages out to<br>
disk.<br>
<br>
Glad it&#39;s now working for you.<br>
<font color="#888888"><br>
Matthew<br>
</font></blockquote></div><br><br clear="all"><br>-- <br><p style="color:rgb(0, 51, 102);font-weight:bold"><span style="border-collapse:separate;font-family:arial;line-height:normal;font-size:small">Cal Leeming</span></p>
<p style="color:rgb(0, 51, 102);font-weight:bold">Operational Security &amp; Support Team<br></p><p style="border-bottom-width:1px;border-bottom-style:solid;border-bottom-color:rgb(204, 204, 204);padding-bottom:25px"><b>Out of Hours: </b>+44 (07534) 971120 | <b>Support Tickets: </b><a href="mailto:support@simplicitymedialtd.co.uk" style="color:rgb(49, 132, 173)" target="_blank">support@simplicitymedialtd.co.uk</a> <br>
<b>Fax: </b>+44 (02476) 578987 | <b>Email: </b><a href="mailto:cal.leeming@simplicitymedialtd.co.uk" style="color:rgb(49, 132, 173)" target="_blank">cal.leeming@simplicitymedialtd.co.uk</a> </p><div><span style="line-height:13px;font-size:10px;color:rgb(185, 184, 184)">Simplicity Media Ltd. All rights reserved.<br>
</span></div><div><span style="line-height:13px;font-size:10px;color:rgb(185, 184, 184)">Registered company number 7143564<span></span><span></span></span></div><br>
</div>