I guess the problem in&nbsp;m_continuationQueue.Next() which returns null,<div>And this is wront usage of Next() acroding to RpcContinuationQueue.Next()</div><div><div>&nbsp; &nbsp; /// &lt;summary&gt;</div><div>&nbsp; &nbsp; /// Retrieve the next waiting continuation.</div><div>&nbsp; &nbsp; /// &lt;/summary&gt;</div><div>&nbsp; &nbsp; ///&nbsp;</div><div>&nbsp; &nbsp; /// &lt;remarks&gt;</div><div>&nbsp; &nbsp; ///&nbsp;</div><div>&nbsp; &nbsp; /// &lt;para&gt;</div><div>&nbsp; &nbsp; /// It is an error to call this method when there are no</div><div>&nbsp; &nbsp; /// &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;waiting continuations. In the current implementation, if</div><div>&nbsp; &nbsp; /// &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;this happens, null will be returned (which will usually</div><div>&nbsp; &nbsp; /// &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;result in an immediate NullPointerException in the</div><div>&nbsp; &nbsp; /// &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;caller). Correct code will always arrange for a</div><div>&nbsp; &nbsp; /// &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;continuation to have been Enqueue()d before calling this</div><div>&nbsp; &nbsp; /// &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;method.</div><div>&nbsp; &nbsp; ///&nbsp;</div><div>&nbsp; &nbsp; /// &lt;/para&gt;</div><div>&nbsp; &nbsp; ///&nbsp;</div><div>&nbsp; &nbsp; /// &lt;/remarks&gt;</div><div>&nbsp; &nbsp; public IRpcContinuation Next()</div><div>&nbsp; &nbsp; {</div><div>&nbsp; &nbsp; &nbsp; lock (this.m_outstandingRpcLock)</div><div>&nbsp; &nbsp; &nbsp; {</div><div>&nbsp; &nbsp; &nbsp; &nbsp; IRpcContinuation local_0 = this.m_outstandingRpc;</div><div>&nbsp; &nbsp; &nbsp; &nbsp; this.m_outstandingRpc = (IRpcContinuation) null;</div><div>&nbsp; &nbsp; &nbsp; &nbsp; return local_0;</div><div>&nbsp; &nbsp; &nbsp; }</div><div>&nbsp; &nbsp; }</div></div><div><br><br>среда, 31 июля 2013&nbsp;г., 15:38:42 UTC+4 пользователь inforser....@gmail.com написал:<blockquote class="gmail_quote" style="margin: 0;margin-left: 0.8ex;border-left: 1px #ccc solid;padding-left: 1ex;"><div>{AMQP close-reason, initiated by Library, code=541, text="Unexpected Exception", classId=0, methodId=0, cause=System.<wbr>NullReferenceException: Object reference not set to an instance of an object.</div><div>&nbsp; &nbsp;at RabbitMQ.Client.Impl.<wbr>ModelBase.HandleBasicGetEmpty(<wbr>)</div><div>&nbsp; &nbsp;at RabbitMQ.Client.Framing.Impl.<wbr>v0_9_1.Model.<wbr>DispatchAsynchronous(Command cmd)</div><div>&nbsp; &nbsp;at RabbitMQ.Client.Impl.<wbr>ModelBase.HandleCommand(<wbr>ISession session, Command cmd)</div><div>&nbsp; &nbsp;at RabbitMQ.Client.Impl.<wbr>SessionBase.OnCommandReceived(<wbr>Command cmd)</div><div>&nbsp; &nbsp;at RabbitMQ.Client.Impl.Session.<wbr>HandleFrame(Frame frame)</div><div>&nbsp; &nbsp;at RabbitMQ.Client.Impl.<wbr>ConnectionBase.<wbr>MainLoopIteration()</div><div>&nbsp; &nbsp;at RabbitMQ.Client.Impl.<wbr>ConnectionBase.MainLoop()}</div></blockquote></div>