0

我目前正试图让我的应用程序能够从我的服务总线接收异步消息。但是，有时会抛出异常，我不知道如何使它消失或从它的来源中消失。

这是一个例外：

Exception: System.NullReferenceException: Object reference not set to an instance of an     object. at GetOffers.DbConnection.processEndReceive(IAsyncResult result);

所以，我知道它来自我的 IASync 方法，但我无法理解它在哪里无法正常工作。

我的 QueueClient 配置：

QClient = QueueClient.CreateFromConnectionString(connectionString, queueStr,ReceiveMode.ReceiveAndDelete);

这是我的两个 IASync 方法：

    void processEndReceive(IAsyncResult result)
    {
        try
        {
            QueueClient qc = result.AsyncState as QueueClient;
            BrokeredMessage message = qc.EndReceive(result);
            ForexData data = new ForexData();

            var newtrade = new Trade(data.OfferId, message.Properties["login"].ToString(), message.Properties["amount"].ToString(), message.Properties["instr"].ToString(), message.Properties["type"].ToString(), data.CreationDate, message.Properties["mode"].ToString(), message.Properties["accountID"].ToString(), message.Properties["idTrade"].ToString());
            //Static Variable for the WHERE (sql) in ResponseListener Line 215. 
            idtradetemp = message.Properties["idTrade"].ToString();
            Console.WriteLine("Received message " + message.Label);
            if (newtrade != null)
            {
                try
                {
                    newtrades.Add(newtrade);
                }
                catch
                {
                    Console.WriteLine("Une erreur est survenue lors l'ajout du message dans la liste 'newtrades'");
                }
                Console.WriteLine("Received Delete: " + DateTime.Now);
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(string.Format("Exception: {0}", e.ToString()));
            TextWriter tw = new StreamWriter("logServiceBus.txt", true);
            tw.WriteLine("Program terminated on " + DateTime.Now);
            tw.WriteLine("------------------------------------");
            tw.WriteLine(string.Format("Exception: {0}", e.ToString()));
            tw.WriteLine("------------------------------------");
            tw.Close();
        }
    }

    void processEndComplete(IAsyncResult result)
    {
        try
        {
            BrokeredMessage m = result.AsyncState as BrokeredMessage;
            m.EndComplete(result);
            Console.WriteLine("Completed message " + m.Label);
        }
        catch
        { 

        }
    }

基本上这些方法是每次他在 ServiceBus 中检测到新消息时触发。问题是，我放了一个 Console.WriteLine("New Message"); 当检测到新消息时，此 CW 被触发 2 次（或更多）。

所以两件事之一：什么会导致我的错误？我怎样才能让我的 IAsync 方法只在此消息上触发一次。

4

1 回答 1

1

使用 Begin/End 对可能难以正确编程。您是否尝试过更新代码以使用 async/await 模式？已发布服务以及服务器上的 Service Bus 1.1 的服务总线库也支持基于任务的 API。有关详细信息，请参阅http://www.windows-azure.net/task-based-apis-for-service-bus/（我是该帖子的作者）。然后，您可以使用 ReceiveAsync。您可能还想查看也可以使用的 OnMessage API。（文档在这里：http: //msdn.microsoft.com/en-us/library/microsoft.servicebus.messaging.queueclient.onmessage.aspx）

于 2014-05-22T00:45:54.160 回答