Azure Service Bus Java: ప్రాక్సీతో WebSockets ద్వారా AMQP ఉపయోగించడం

Azure Service Bus యొక్క ఆధునిక Java సందేశ క్లయింట్ 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 ఉపయోగించండి. Azure యొక్క HTTP స్టాక్‌లో సమానమైన పేరుతో మరో ప్రాక్సీ ఎంపికల తరగతి ఉంది; అది ఈ బిల్డర్ అంగీకరించే రకం కాదు.

ఇది సందేశ కనెక్షన్‌ను కాన్ఫిగర్ చేస్తుంది. స్వతంత్రంగా సృష్టించిన గుర్తింపు ఆధారాలను ఉపయోగించే అప్లికేషన్ ఆ ఆధారాల టోకెన్ HTTP రవాణాను కూడా కాన్ఫిగర్ చేయాల్సి రావచ్చు.

పాత Azure SDK 0.9 ఉదాహరణలు మరో క్లయింట్ తరాన్ని సూచిస్తాయి. దాని కాన్ఫిగరేషన్ స్థిరాంకాలు లేదా సాధారణ HTTP లక్షణాలు ఆధునిక AMQP బిల్డర్‌ను వివరిస్తాయని ఊహించవద్దు.