我一直在尝试创建一个客户端来连接我的Azure服务总线队列。我一直在参考此文档:
https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-queues#send-消息到队列。
我的代码:
public void run() throws Exception {
try {
final String ConnectionString = "<My connection String> ";
final String QueueName = "queue1";
QueueClient sendClient = new QueueClient(new
ConnectionStringBuilder(ConnectionString, QueueName),
ReceiveMode.PEEKLOCK);
System.out.println("sendClient created");
sendClient.close();
} catch(Exception e) {
System.err.println(e);
}
}
在创建客户端时,我遇到以下错误:
通用域名格式。微软蔚蓝色的服务总线。原语。ServiceBusException:Error{condition=amqp:connection:framing Error,description='org.apache.qpid.proton.engine.TransportException:connection aborted',info=null}
你是公司代理人的幕后黑手吗?然后,您需要切换到HTTP连接(AMQP Web套接字),而不是AMQP连接。
我想你的连接没有打开。你能不能试试queueClient.open(),同时检查SDK的版本,更新到新版本,请参考这个链接:https://github.com/Azure/azure-service-bus-java/issues/329
根据上面的链接,这将是因为一些网络限制。尝试从您自己的网络连接,并检查其是否工作。。。
我使用此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
我正在寻找一种解决方案,用于在几个本地数据库之间进行实时数据集成。没有太多的数据转换。我正在评估各种可用的ESB。我认为使用Azure服务总线进行数据集成可以快速开发解决方案。建议使用Azure service bus集成所有内部数据库吗?
我已经创建了一个Azure webwork,它将向服务总线队列发送强类型消息,并成功发送。 我想创建另一个webjob,只要servicebus队列中有消息,就会触发该webjob。请在下面找到我正在尝试的代码。出于某种原因,尽管servicebus队列中有消息,但当我在本地运行webjob时,webjob未被触发并出现错误。 错误: 代码: 有谁能帮我解决这个问题吗? 谢谢
但是,我得到以下例外情况: Microsoft.Azure.WebJobs.Host.FunctionInvocationException:执行函数时发生异常:Functions.ProcessQueueMessage2Async---->System.Runtime.Serialization.InvalidDataContractException:无法序列化类型“MyException”。
今天晚上,我们观察到排队时间非常慢。我们的追踪数据告诉我们 需要45-60秒。这种情况发生在两个已经存在很长时间的队列上。他们几乎从来没有超过1-2条记录,我们使用一个带有服务总线触发器的网络作业来完成任务。我们正在排队等候一个简单的POCO。还有另一个队列正在快速排队,所以由于没有任何其他想法,我删除了两个麻烦的队列。当代码重新创建它们时(正如它被构建时所做的那样),它们在不到一秒钟的时间里开始
来自第三次订阅的消息会发生什么情况,是否会在TTL之后发送到死信队列 有没有办法找出消息未被使用的订阅