Я пытался заставить клиента подключиться к моей очереди служебной шины Azure.Я имел в виду эту документацию:
https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-queues#send-messages-to-a-queue.
Мой код:
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: Ошибка {условие = amqp: соединение: ошибка кадрирования, описание = 'org.apache.qpid.proton.engine.TransportException: соединение прервано', info = null}