How to get TopologyManager using DI or builder in ASP.NET Core App

[pgarbo]

Hi,

I am using ArtemisNetClient.Extensions.DependencyInjection in ASP.NET Core application and I need to call ITopologyManager.DeclareQueueAsync before sending any message (to ensure last-value queue is created). How can I get access to the topology manager using DI or IActiveMqBuilder and where is the best way to call it?

thanks,
Pawel

[Havret]

Hi @pgarbo,

To keep things simple I never exposed ITopologyManager as part of Extensions.DependencyInjection. You could use this interface implicitly by registering consumer or producer with custom configuration:

dotnet-activemq-artemis-client/src/ArtemisNetClient.Extensions.DependencyInjection/ActiveMqArtemisClientDependencyInjectionExtensions.cs

Line 222 in 49f7056

public static IActiveMqBuilder AddConsumer(this IActiveMqBuilder builder, string address, RoutingType routingType, string queue, ConsumerOptions consumerOptions, QueueOptions queueOptions,

Then you would need to enable address and/or queue declaration:

activeMqBuilder.AddConsumer(address, RoutingType.Multicast, queue, new QueueOptions
    {
        LastValueKey = "my-key",
        NonDestructive = true,
    }, MessageHandler)
    .EnableAddressDeclaration()
    .EnableQueueDeclaration();

In most of the use cases I've seen so far you want to configure address as part of your producer application, and you want to configure queue as part of your consumer application. It your case it clearly doesn't seem to be the case. I guess we could add the option to register custom ConfigureTopology delegate that will give you access to ITopologyManager and will be executed as part of the app startup, right before producers and consumers are brought to life. We have sth similar already available for connection configuration.

Please let me know if sth along these lines will work for you.

activeMqBuilder.ConfigureTopology(async (_, topologyManager) =>
{
    await topologyManager.CreateQueueAsync(new QueueConfiguration
    {
        Address = addressName,
        Name = queueName,
        AutoCreateAddress = true
    });
});

Thanks,
Havret

[pgarbo]

Hi,

Yes, ConfigureTopology delegate would be ideal.

Thanks,
Pawel

[Havret]

Please check 2.11.0.