Azure Service Bus Java: AMQP przez WebSockets z użyciem serwera proxy

Nowoczesny klient obsługi komunikatów Java usługi Azure Service Bus używa AMQP. Jego konstruktor wymaga AMQP_WEB_SOCKETS, gdy skonfigurowano serwer proxy.

W wersji azure-messaging-servicebus 7.18.0 nadawcę buduje się następująco:

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

Zmienne konta uwierzytelniają się względem serwera proxy akceptującego Basic. Parametry połączenia i nazwa kolejki nadal identyfikują zasób Service Bus. Zachowaj utworzonego nadawcę przez zamierzony okres jego życia i zamknij go, gdy aplikacja zakończy z nim pracę.

Użyj tutaj klasy com.azure.core.amqp.ProxyOptions. Stos HTTP platformy Azure ma inną klasę opcji serwera proxy o podobnej nazwie; nie jest to typ akceptowany przez ten konstruktor.

To konfiguruje połączenie obsługi komunikatów. Aplikacja korzystająca z samodzielnie utworzonych poświadczeń tożsamości może również wymagać skonfigurowania transportu HTTP tokenu tych poświadczeń.

Stare przykłady dla Azure SDK 0.9 odnoszą się do innej generacji klienta. Nie zakładaj, że jego stałe konfiguracyjne lub ogólne właściwości HTTP opisują nowoczesny konstruktor AMQP.