azureservicebus

0热度

3回答

我有2个问题，我没有找到任何解决方案。是否有任何内置的方式在蔚蓝的服务总线队列，在这里我只能从我的会话处理程序一个会话（该阶段ID）接收消息。也有什么办法可以只接收来自该会话的静态队列的消息。我可以在我的代码中以编程方式执行此操作，但我不想在代码中编写其他逻辑。

0热度

1回答

OperationCanceledException当发送到服务总线

我收到OperationCanceledException当我发送消息到主题队列（我正在从Azure函数内运行我的代码）。我使用的版本是：“WindowsAzure.ServiceBus”：“4.1.1”（最新）当我进行负载测试时意味着许多消息正在此服务总线中发送（包含多个主题）。我被告知使用重试机制为： client.RetryPolicy = new RetryExponential(m

0热度

1回答

如何从azure服务总线队列读取xml文件数据

我只想读取已从队列发送到azure服务总线的XML文件数据。我的代码是 while (client.Peek() != null) { BrokeredMessage orderOutMsg = client.Receive(); if (orderOutMsg != null) { // Deserialize the message body to

0热度

1回答

如何为azure服务总线中的每条中断消息重置“delivery count”？

实时，我有几个天蓝色的服务总线队列。每个队列都有其自己的消息传递计数的默认限制。当它超过交付计数时，消息将转移到“死信队列”。现在我必须重新发布DeadLetter消息到原始队列进行重新处理。由于交货计数，它将信息推回死信。我不想更改队列最大交付计数。现在，我怎样才能重置每个破碎的消息交付计数？

0热度

1回答

AMQP 1.0和交易

我与Azure的服务总线评估AMQP 1.0在一起，目前正在查找的事务支持 - 2阶段提交协调与读/写邮件到总线）的数据库插入/更新/删除。在我的测试中为.Net使用“Amqp.Net Lite”。不Azure的服务总线支持2PC交易？不AMQP 1.0和Amqp.Net精简版支持2PC交易？（任何代码示例？）

0热度

2回答

Azure Servicebus messageid始终为空

我有一个相当简单的函数，它向蔚蓝的服务总线队列发送消息。 public async Task<string> SendMessagesToQueue(string serviceBusConnectionString, int message, string queueName) { try { QueueClient queueClient = n

1热度

2回答

为什么连续调用ICommunicationListener.Abort（）？

下面是在本地SF集群中运行并监听服务总线队列的无状态服务侦听器代码。我想要的是不断地在永远在线的SF服务中监听队列命令。代码改进提示是受欢迎的！问题＃1 中止（）连续调用，有效地关闭我的连接。什么是造成这种行为，我该如何解决它？在我的理解中，Abort（）应该只在未处理的异常或强制关闭的情况下被调用，这两者我都没有意识到。奖金问题说我们注释掉中止（）的调用CloseClient，它允许正确

2热度

1回答

Azure的功能服务总线触发：让试图绑定到自定义类

我创建与服务总线触发了Azure的功能，并试图进入的消息绑定到自定义类矿井时系列化例外： public class InputMessage { public string EntityId { get; set; } } public static string Run(InputMessage message, TraceWriter log) { log.Inf

0热度

2回答

Azure服务总线主题订户锁定已过期异常

我有一个web作业，它通过注册OnMessage回调消耗Azure服务总线主题的消息。所述消息锁持续时间设定为30秒和锁更新超时到60秒。由于此类工作采取超过30秒来处理服务总线消息正在得到锁过期异常。现在，我已将消息锁定持续时间设置为多于锁定更新超时。但不知何故，它仍然会抛出同样的例外。我也重新启动了我的webjob，但仍然没有运气。我试着用后设置运行相同webjob消耗来自不同的主题消息和

4热度

1回答

如何使用自定义的INameResolver配置服务总线触发的Azure功能？

我希望能够控制Azure功能在运行时读取的服务总线队列或订阅的名称。随着WebJobs（其Azure的功能都是基于），你可以通过实现和配置自定义INameResolver为此，请参阅：How to have a configuration based queue name for web job processing? 然而，随着Azure的功能我没有进入JobHostConfiguration