Не могу подключиться к теме Azure Service Bus с помощью Java

Question

Я пытаюсь подключиться к теме служебной шины Azure, используя код Java.Я создал тему на портале Azure.

Я пытаюсь настроить с помощью метода configureWithWrapAuthentication, который имеет параметры namespace, authenticationName, authenticationPassword, serviceBusRootUri, wrapRootUri .

Я получил все значения параметров, кроме wrapRootUri.К вашему сведению: я выбрал регион как Южная Индия

Мне нужно знать, каково значение wrapRootUri для местоположения в Южной Индии.

Пожалуйста, помогите!Заранее спасибо.

Answer 1

Команда сервисного автобуса при переходе с ACS на SAS.Кажется, это больше не работает.Согласно github, существует открытый выпуск .

Если вы хотите подключиться или управлять служебной шиной Azure.Я рекомендую вам использовать следующий SDK .

<!-- https://mvnrepository.com/artifact/com.microsoft.azure/azure-servicebus -->
<dependency>
    <groupId>com.microsoft.azure</groupId>
    <artifactId>azure-servicebus</artifactId>
    <version>2.0.0-PREVIEW-5</version>
</dependency>

Обновление : добавить информацию о пакете.

Демонстрационный код

import com.microsoft.azure.servicebus.ClientSettings;
import com.microsoft.azure.servicebus.Message;
import com.microsoft.azure.servicebus.TopicClient;
import com.microsoft.azure.servicebus.management.ManagementClient;
import com.microsoft.azure.servicebus.management.TopicDescription;
import com.microsoft.azure.servicebus.primitives.ConnectionStringBuilder;
import com.microsoft.azure.servicebus.security.SharedAccessSignatureTokenProvider;
import com.microsoft.azure.servicebus.security.TokenProvider;


 String connectionString = "Endpoint=sb://yoursevicebusNamespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxxxx";
 ConnectionStringBuilder connectionStringBuilder = new ConnectionStringBuilder(connectionString);
 ManagementClient client = new ManagementClient(connectionStringBuilder);
 //create topic
 if(!client.queueExists("topicName")) 
 {
    TopicDescription topic = client.createTopic("topicName");

 }

 TokenProvider tokenProvider = new SharedAccessSignatureTokenProvider("RootManageSharedAccessKey","xxxxxx",30);
 ClientSettings clientSettings = new ClientSettings(tokenProvider){};
 //create topicClient
 TopicClient topicClient = new TopicClient(connectionStringBuilder.getEndpoint(),"topicName",clientSettings);
 //send message
 topicClient.send(new Message("test message"));