Question 412203 in Azure Question posted in
The official documentation to get you started can be found here.

Azure service bus: how to get topics

I’m totally new with Azure Service Bus, and just for studing I’m trying to get topics. If I’m not wrong I should use class ServiceBusAdministrationClient but when I tried to achieve my goal I got the error "InvalidSignature: The token has an invalid signature".

I’m using the easiest constructor (https://learn.microsoft.com/en-us/dotnet/api/azure.messaging.servicebus.administration.servicebusadministrationclient.-ctor?view=azure-dotnet#azure-messaging-servicebus-administration-servicebusadministrationclient-ctor(system-string) ) passing the same connectionString that allows me to send and receive messages using ServiceBusClient.

Theorically I should be able to do that using the same connection string, I think that because the Service Bus Explorer developed by Paolo Salvatori (https://github.com/paolosalvatori/ServiceBusExplorer) is able to do that with the same connection string. Am I wrong or do I need a different connection string?

Here the code I have (copied from another post):

var administrationClient = new ServiceBusAdministrationClient(ConnectionString);
AsyncPageable<TopicProperties> allTopics = administrationClient.GetTopicsAsync();
await foreach (TopicProperties topic in allTopics)
{
    Console.WriteLine($"IterateTopicsWithAwaitForeachAsync: {topic.Name}");
}

Can anyone please explain me what I’m doing wrong?

ps. I’m using .net 8

Tags:

2

Answers


  1. 0 
    var administrationClient = new ServiceBusAdministrationClient(ConnectionString);
AsyncPageable<TopicProperties> allTopics = administrationClient.GetTopicsAsync();
await foreach (TopicProperties topic in allTopics)
{
    Console.WriteLine($"IterateTopicsWithAwaitForeachAsync: {topic.Name}");
}

    This code is working fine. I’d double-check your connection string. Also, it is worth noting that the administrative client works via HTTP while the data client works via AMQP by default. So, there might be a chance that your data operations are working while management operations fail if HTTP traffic is blocked.

    Login or Signup to reply.
  2. 0

    Thanks @Sean Feldman and I do agree that there might be a chance of Traffic being blocked otherwise if you give correct connection string, it will work and I have taken connection string from below:

    enter image description here

    The topics i have are:

    enter image description here

    With Azure.Messaging.ServiceBus.Administration package(ServiceBusAdministrationClient) :

    using Azure.Messaging.ServiceBus.Administration;

string ri_cs = "Endpoint=sb://rithtest.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=6YXOZY=";
var ri_cl = new ServiceBusAdministrationClient(ri_cs);
var ri_tp = ri_cl.GetTopicsAsync();
await foreach (var ri in ri_tp)
{
    Console.WriteLine($"Hello Rithwik Bojja, Topic Name: {ri.Name}");
}

    Output:

    enter image description here

    Alterantively you can use Microsoft.Azure.ServiceBus.Management package(ManagementClient) :

    using Microsoft.Azure.ServiceBus.Management;

string ri_cs = "Endpoint=sb://rithtest.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=6YXOhY=";
var ri_cl = new ManagementClient(ri_cs);
var rith = await ri_cl.GetTopicsAsync();
foreach (var ri in rith)
{
    Console.WriteLine(ri.Path);
}

    Output:

    enter image description here

    Login or Signup to reply.
Please signup or login to give your own answer.

Back To Top
Search