java无法使用Azure服务总线发送消息

Question

Dotnet示例（发送/接收）工作正常。 从java我无法发送消息，但接收消息工作正常

private boolean connectServer()
{
    try {
        if (null != senderClient) return true;
        senderClient = new ServiceBusClientBuilder()
                .connectionString(connectionString)
                .transportType(AmqpTransportType.AMQP_WEB_SOCKETS)
                .sender()
                .queueName(queueName)
                .buildAsyncClient();
        return true;
    }
    catch (Exception ex)
    {
        System.out.println(ex);
        return false;
    }
}



public boolean sendMessage(String message) throws InterruptedException {
    try {
        connectServer();
        senderClient.sendMessage(new ServiceBusMessage(BinaryData.fromString(message)));
        return true;
    }
    catch (Exception ex)
    {
        System.out.println(ex);
        return false;
    }
}

我没有得到任何错误。在Azure portal --> Overview中。我可以看到多个传入请求，但传入消息为0

Answer 1

关于该问题，请参考以下代码

ServiceBusSenderClient senderClient = new ServiceBusClientBuilder()
                .connectionString(connectionString)
                .sender()
                .queueName(queueName)
                .buildClient();

        ServiceBusMessage message = new ServiceBusMessage("Hello world!");
        senderClient.sendMessage(message);
        System.out.println("Sent  messages to the queue: " + queueName);