- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
如何停止从设置为事件驱动消息泵的订阅客户端接收消息?我目前有一些代码可以工作,但是当我连续运行两个测试时,它们会第二次中断。我相当确定消息仍在从我创建的第一个实例中的订阅中提取。
http://msdn.microsoft.com/en-us/library/dn130336.aspx
OnMessageOptions options = new OnMessageOptions();
options.AutoComplete = true; // Indicates if the message-pump should call complete on messages after the callback has completed processing.
options.MaxConcurrentCalls = 1; // Indicates the maximum number of concurrent calls to the callback the pump should initiate
options.ExceptionReceived += LogErrors; // Enables you to be notified of any errors encountered by the message pump
// Start receiveing messages
Client.OnMessage((receivedMessage) => // Initiates the message pump and callback is invoked for each message that is received. Calling Close() on the client will stop the pump.
{
// Process the message
Trace.WriteLine("Processing", receivedMessage.SequenceNumber.ToString());
}, options);
最佳答案
你需要做两件事。
首先,调用 subscriptionClient.Close()
,这最终将(但不会立即)停止消息泵。
其次,在您的消息收到回调时,检查客户端是否已关闭,如下所示:
if (subscriptionClient.IsClosed)
return;
关于c# - 停止接收来自 SubscriptionClient 的消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17025338/
subscriptionClient.AbandonAsync 与 subscriptionClient.closeAsync 之间有什么区别。 我需要检查订阅客户端中是否存在主题。由于某些限制,我无
在 Azure 服务总线命名空间中,有一个 SubscriptionClient 类型,具有以这种方式启动 MessageSession 的方法:- MessageSession session =
在 Azure 服务总线命名空间中,有一个 SubscriptionClient 类型,具有以这种方式启动 MessageSession 的方法:- MessageSession session =
我正在使用 Azure 服务总线云服务和 Microsoft.Azure.ServiceBus 3.2.0 NuGet 包。我正在研究这个主题。 当我广告 SubscriptionClient 规则来
我正在尝试使用 Azure SubscriptionClient.PeekBatch(int count) 来查看消息。对于 0 - 9 的计数值,一切正常,但一旦我输入 > 9 的值,我只会收到 9
我有一个控制台应用程序来读取 Azure 服务总线上的订阅中存在的所有代理消息。我那里有大约 3500 条消息。这是我读取消息的代码: SubscriptionClient client = mess
如何停止从设置为事件驱动消息泵的订阅客户端接收消息?我目前有一些代码可以工作,但是当我连续运行两个测试时,它们会第二次中断。我相当确定消息仍在从我创建的第一个实例中的订阅中提取。 http://msd
我正在努力解决消息在死信队列中过快结束的问题。我已经指定了这样的 ExponentialRetry 策略: private readonly RetryExponential _ret
当订阅需要 session 时,Azure 服务总线订阅客户端是否支持使用 OnMessage 操作? 我有一个订阅,名为“TestSubscription”。它需要一个 sessionId 并包含通
如果我向某个主题发送一批消息,并使用订阅客户端读取消息,那么我似乎会按顺序接收消息,即每发送一条消息都会触发 OnMessageAsync,但是有一个每个接收事件之间有明显的(150+ 毫秒)延迟 发
如果我向某个主题发送一批消息,并使用订阅客户端读取消息,那么我似乎会按顺序接收消息,即每发送一条消息都会触发 OnMessageAsync,但是有一个每个接收事件之间有明显的(150+ 毫秒)延迟 发
我一直在研究 Azure 服务总线 2.0 版提供的新消息泵。特别是,我使用主题和订阅(而不是队列)。 我可以让消息泵与非 session 订阅一起工作,并且只要有brokeredMessage可用,
我在 SubscriptionClient 上调用 BeginReceive(),如下所示: client.BeginReceive(new TimeSpan(6, 0, 0), new AsyncC
我正在 .net Core 2.1 中编写一个控制台应用程序,我的目的是监听 ServiceBus 中某个主题的消息,并使用 NEST api 处理到达 Elasticsearch 的新消息(NEST
我正在尝试实现重试政策,但它一直被忽略。SubscriptionClient 中是否有属性覆盖我在创建客户端时提供的属性? 这是我试过的代码: _retryPolicy = new Microsoft
这很奇怪,我不确定,但我记得不久前我做了这样的事情 SubscriptionClient Client = SubscriptionClient.CreateFromConnectionString(
这很奇怪,我不确定,但我记得不久前我做了这样的事情 SubscriptionClient Client = SubscriptionClient.CreateFromConnectionString(
根据 Hasura 中的用户角色动态更改 Apollo SubscriptionClient 中的 header 的正确方法是什么? 堆: 下一篇JS 阿波罗 Auth0 Hasura(使用角色列存储
我是一名优秀的程序员,十分优秀!