Azure Service Bus Java: AMQP kasutamine WebSocketsi kaudu puhverserveriga

Seadistage Azure Service Busi Java-sõnumiklient kasutama AMQP-d WebSocketsi kaudu ja AMQP teegi puhverserveri seadeid.

Azure Service Busi kaasaegne Java-sõnumiklient kasutab AMQP-d. Selle ehitaja nõuab AMQP_WEB_SOCKETS, kui puhverserver on seadistatud.

azure-messaging-servicebus 7.18.0 puhul ehitage saatja järgmiselt:

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

Konto muutujad autentivad end puhverserveri vastu, mis aktsepteerib Basicut. Ühendusstring ja järjekorra nimi määravad endiselt Service Busi ressursi. Hoidke loodud saatjat selle ettenähtud eluea jooksul ja sulgege see, kui rakendus on sellega lõpetanud.

Kasutage siin com.azure.core.amqp.ProxyOptions. Azure'i HTTP-pinul on teine sarnase nimega puhverserveri valikute klass; see ei ole tüüp, mida see ehitaja aktsepteerib.

See seadistab sõnumiühenduse. Rakendus, mis kasutab iseseisvalt loodud identiteedi mandaate, võib samuti vajada nende mandaatide loa HTTP-transpordi seadistamist.

Vanad Azure SDK 0.9 näited viitavad teisele kliendipõlvkonnale. Ärge järeldage, et selle seadistuskonstandid või üldised HTTP-omadused kirjeldavad kaasaegset AMQP ehitajat.

Seotud artiklid