Azure Service Bus Java: AMQP через WebSockets із проксі

Налаштуйте Java-клієнт обміну повідомленнями Azure Service Bus на AMQP через WebSockets із параметрами проксі бібліотеки AMQP.

Сучасний Java-клієнт обміну повідомленнями Azure Service Bus використовує AMQP. Його будівник вимагає AMQP_WEB_SOCKETS, коли налаштовано проксі.

З azure-messaging-servicebus 7.18.0 відправник створюється так:

var address = new java.net.Proxy(
    java.net.Proxy.Type.HTTP,
    new java.net.InetSocketAddress("proxy.example", 8080));

var proxy = new com.azure.core.amqp.ProxyOptions(
    com.azure.core.amqp.ProxyAuthenticationType.BASIC,
    address, proxyUser, proxyPassword);

var sender = new com.azure.messaging.servicebus.ServiceBusClientBuilder()
    .connectionString(serviceBusConnectionString)
    .transportType(com.azure.core.amqp.AmqpTransportType.AMQP_WEB_SOCKETS)
    .proxyOptions(proxy)
    .sender()
    .queueName(queueName)
    .buildClient();

Змінні облікового запису автентифікуються через проксі, що приймає Basic. Рядок підключення та назва черги досі визначають ресурс Service Bus. Тримайте створений відправник протягом передбаченого терміну служби та закривайте його, коли застосунок завершить із ним роботу.

Тут використовуйте com.azure.core.amqp.ProxyOptions. У HTTP-стеку Azure є інший клас параметрів проксі зі схожою назвою; це не той тип, який приймає цей будівник.

Це налаштовує з'єднання обміну повідомленнями. Застосунку, який використовує самостійно створені облікові дані ідентичності, може також знадобитися налаштувати HTTP-транспорт токена цих даних.

Старі приклади для Azure SDK 0.9 стосуються іншого покоління клієнта. Не робіть висновку, що його константи налаштування або загальні властивості HTTP описують сучасний будівник AMQP.

Схожі статті