How to delete a queue in ActiveMq

99 views
Skip to first unread message

martin setterstig

unread,
Jul 4, 2022, 5:21:07 AM7/4/22
to masstransit-discuss

How can I delete a queue in ActiveMQ

When setting Endpoint to temporary the queue is not delete when the consumer exit. It is working when using RabbitMQ but not ActiveMQ.

Here is my code

 

public static IHostBuilder CreateHostBuilder(string[] args, string? instanceId)

        {

            return Host.CreateDefaultBuilder(args).ConfigureServices((hostContext, services) =>

            {  

                services.AddMassTransit(busConfig =>

                {

                    busConfig.SetKebabCaseEndpointNameFormatter();

                    var entryAssembly = Assembly.GetEntryAssembly();

                    busConfig.AddConsumer<OperationDefinitionConsumer>(typeof(OperationDefinitionConsumerDefinition))

                    .Endpoint(endpoiintConfig =>

                    {

                        endpoiintConfig.Name = "operation-Definition";

                        endpoiintConfig.Temporary = true;

                        endpoiintConfig.InstanceId = "_" + instanceId;

 

                    });                   

                    busConfig.AddSagaStateMachines(entryAssembly);

                    busConfig.AddSagas(entryAssembly);

                    busConfig.AddActivities(entryAssembly);

                    //UseRabbitMq(busConfig);

                    UseActiveMq(busConfig);

                });

            });

        }

           

        private static void UseActiveMq(IBusRegistrationConfigurator busRegConfig)

        {

            busRegConfig.UsingActiveMq((context, busConfig) =>

            {

                busConfig.AutoDelete = true;

                busConfig.UseDelayedMessageScheduler();

                busConfig.Host("localhost", 61616, hostConfig =>

                {

                    hostConfig.Username("guest");

                    hostConfig.Password("guest");

                });               

                busConfig.EnableArtemisCompatibility();

                busConfig.ConfigureEndpoints(context);

            });

        }

        private static void UseRabbitMq(IBusRegistrationConfigurator busRegConfig)

        {

            busRegConfig.UsingRabbitMq((context, busConfig) =>

            {

                busConfig.AutoDelete = true;

                busConfig.Host("localhost", "/", hostConfig =>

                {

                    hostConfig.Username("guest");

                    hostConfig.Password("guest");

                });                               

                busConfig.ConfigureEndpoints(context);

            });                       

        }

 

Jerry Lee Daniel

unread,
Nov 27, 2023, 5:33:42 PM11/27/23
to masstransit-discuss
MT103/202 DIRECT WIRE TRANSFER
PAYPAL TRANSFER
CASHAPP TRANSFER
ZELLE TRANSFER
TRANSFER WISE
WESTERN UNION TRANSFER
BITCOIN FLASHING
BANK ACCOUNT LOADING/FLASHING
IBAN TO IBAN TRANSFER
MONEYGRAM TRANSFER
IPIP/DTC
SLBC PROVIDER
CREDIT CARD TOP UP
DUMPS/ PINS
SEPA TRANSFER
WIRE TRANSFER
BITCOIN TOP UP
GLOBALPAY INC US
SKRILL USA
UNIONPAY RECEIVER

Thanks.


NOTE; ONLY SERIOUS / RELIABLE RECEIVERS CAN CONTACT.

DM ME ON WHATSAPP
+44 7405 896213
Reply all
Reply to author
Forward
0 new messages