我是Azure服务总线的新手。
我正在尝试将消息添加到Azure服务总线队列,如下所示
var message = new BrokeredMessage() { Label = inputFileEntity.FileName };
message.MessageId = new Guid().ToString();
message.Properties.Add("FilePath", inputFileEntity.FilePath);
// submit the file for injector
QueueConnector.InputFileQueueClient.Send(message);
我收到如下MessageCommunication异常
Channel Open did not complete within the specified timeout of 00:01:00
当我初始化QueueClient时,我甚至将操作超时值配置为10分钟,仍然是相同的问题
var namespaceManager = CreateNamespaceManager();
namespaceManager.Settings.OperationTimeout = new TimeSpan(0, 10, 0);
在我出错的地方,任何方向或指针都会有很大的帮助。
这通常表示存在网络问题,因为可能有防火墙阻止TCP端口上的出站通信。您还可以将连接模式设置为http,并通过端口80发送流量。
ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Http;
我一直在尝试创建一个客户端来连接我的Azure服务总线队列。我一直在参考此文档: https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-queues#send-消息到队列。 我的代码: 在创建客户端时,我遇到以下错误: 通用域名格式。微软蔚蓝色的服务总线。原语。Service
我有一个超时选项,只想在超时前接收消息。 如果您能解释下面的代码是如何工作的,以及我如何修改下面的代码以在特定的时间框架内接收消息,并且一旦我的超时已经到达就停止接收,这将是很有帮助的。
我使用此url中的示例http://azure.microsoft.com/en-us/documentation/articles/service-bus-java-how-to-use-jms-api-amqp/.我有两个问题: 1、ACS或SAS 连接URL, 用户名和密码来自ACS身份验证,但Azure服务总线已将其身份验证从ACS更改为SAS。它是否也支持SAS身份验证?就像用户名是SA
我正在尝试在Azure中构建一个简单的WebAPI REST服务,后端有一个服务总线队列工作器。我可以从Web API向工作人员发送一条消息。然而,我试图发送更多的信息,只是为了看看一切是如何运作的。因此,我创建了一个简单的控制器,如下所示: 当我呼叫控制器时,我只收到工作人员接收到的大约1/2的消息。其余的似乎都被放弃了。
我在Azure中托管了两个云服务辅助角色,一个使用NServiceBus(Azure服务总线传输)消耗消息,另一个生成消息。 昨天,我部署了一个新版本的生产者工作者角色,而队列中仍然有大量消息,因为我们正在处理早上遗留下来的大量消息。当生产者启动时,它似乎已经清空(或者可能重新创建)队列,许多重要的生产消息丢失。这似乎很奇怪,但日志显示,大约在生产者角色启动时,消费者没有处理进一步的消息,我们知道
> 在Azure Service Bus主题中,我有两个订阅subscription1和subscription2。我正在向主题发送一条消息。在subscription1中,消息被放弃,在subscription2中,消息被处理。subscription1中的已放弃消息是否将再次发送给两个订阅或仅发送给已放弃消息的订阅。 我也有点困惑,死信队列将是所有订阅都通用的,还是每个订阅都有一个单独的死信队