brokeredmessage

0热度

1回答

我试图使用基于消息属性的消息路由将设备消息路由到IotHub。我将它们路由到服务总线主题。但是，我看到的是，尽管发送给IoTHub之前设置 Microsoft.Azure.Devices.Client.Message 类的ContentType属性，相同的属性是没有看到填充的消息路由成功后发出的Brokered消息。有什么我在这里失踪？代码在设备侧： BrokeredMessage msgFr

1热度

2回答

使用SendBatchAsync方法向服务总线发送1000个中介消息

我有一个应用程序，其中数据从SQL DB中获取并作为中介消息发送到服务总线。这些步骤如下：从DB 数据取出（在1000批次）转换成牵线消息，并添加到列表中的数据的每一行。 1000个代理消息的列表使用SendBatchAsync方法发送到服务总线。这是我第三步面对的问题。这是代码为： public async Task SendMessagesAsync(List<BrokeredMessag

0热度

1回答

（Azure）BrokeredMessage.GetBody <xxx>

我试图把一个'通用'订户放在一起，我可以（重新）使用Azure ServiceBus。但我坚持如下; 我的代码曾经剥离过非必要部分，看起来像这样。 Subscribing.Client.OnMessage((recdMessage => { var msgBody = recdMessage.GetBody<myClass>(); }, options); 我希望我的msgBo

5热度

3回答

BrokeredMessage配置

我在编辑BrokeredMessage时遇到了麻烦。简单的代码，就像预期： private void OnMessageArrived(BrokeredMessage message) { var myObj= message.GetBody<MyObject>(); //do things with myObj message.Complete();

0热度

1回答

从Azure服务总线订阅中获取所有代理消息

我正在使用Azure服务总线订阅和主题发送订单和获取订单。我们有一个Windows应用程序，它使用来自Azure服务总线订阅的Web API来下订单。假设用户登录并获得5个订单。如果用户从Windows应用程序注销，然后我们解锁来自天蓝色服务总线的消息。并且如果用户在5分钟或更少时间后再次登录，那么我们没有从天蓝色的服务总线获取所有订单。它有时像3或4。任何人都可以帮助我解决这个问题，为什么我

0热度

1回答

Azure服务总线队列消息处理

所以我有一个azure函数作为调用内部托管的API的队列触发器。关于如何处理由于除有毒以外的问题而无法处理的消息，似乎没有在线确定的答案。一个例子：接收我的消息和功能试图调用API。消息有效负载是正确的，可以处理，但无论什么原因，API /服务都会关闭（这段时间可能会超过10分钟）。目前发生的事情是消息传递计数达到其最大值（10），然后被推送到死信队列中，而这又会发生在每个消息之后。我需要

3热度

2回答

在本地使用Azure服务总线

我正在使用Azure服务总线主题和订阅。它被用来在整个应用程序中发送控制消息。消息侦听器（订阅者）正在工作角色中运行，他们正在拾取消息并处理请求。即使有多个侦听器同时运行，总线中的每条消息也只能被拾取一次。使用服务总线没有问题;但是我们在调试/测试本地应用程序时遇到了一些问题。我们有2条服务总线，一条用于云端，一条用于本地调试。现在，如果多个人同时调试应用程序，则该消息仅由系统中的一个（随机）选

0热度

2回答

如何在azureservicebus中查看并删除deadletter的邮件

我创建了一个蔚蓝的服务总线主题应用程序，它可以查看deadletter中的所有消息。一些特定的消息（特别是messageid）我偷看需要从死信队列中删除。请为实现这个提供帮助。非常感谢

0热度

2回答

BrokeredMessage Azure ServiceBus的虚假投递和接收

我已经创建了BrokeredMessage的一个实例，并且希望围绕它的deliverycount测试我的代码与队列的最大投递计数。我不想站立一个真正的队列来发送和接收消息，但deliverycount属性在消息传递之前不会被初始化。我怎么能伪造这个？

1热度

1回答

C＃服务总线多个侦听器都收到相同的消息（BrokeredMessage）

我曾经使用RabbitMQ作为消息传递平台，我从来没有遇到过任何问题 - 不幸的是，最近我们将基础架构迁移到了Azure，提供RabbitMQ服务器，所以我想过尝试Service Bus扩展。我有一个作家和多个读者。目前，读者将分别读取不同的消息（消息竞争模式 - 例如对负载平衡有益）。我想要的是，所有的读者都得到相同的信息并自行处理。读者（S）： string connectionKey