首页 > 解决方案 > Azure 服务总线异常

问题描述

我一直在尝试让客户端连接我的 Azure 服务总线队列。我一直在参考这个文档:
https ://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-queues#send-messages-to -一个队列

我的代码:

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);
    }
}

在创建客户时,我收到以下错误:

com.microsoft.azure.servicebus.primitives.ServiceBusException: 错误{condition=amqp:connection:framing-error, description='org.apache.qpid.proton.engine.TransportException: connection aborted', info=null}

标签: javaazureservicebus

解决方案


我认为您的连接未打开。您能否尝试 queueClient.open() 并检查 SDK 的版本,将其更新到新版本,请参阅此链接: https ://github.com/Azure/azure-service-bus-java/issues/329

根据上面的链接,可能是因为一些网络限制。尝试连接来自您自己的网络并检查它是否有效...


推荐阅读