/C#/How to make rabbitmq start and stop base on c# services

How to make rabbitmq start and stop base on c# services

        public async Task StartConsuming(IMessageBusConsumer consumer, MessageBusConsumerName fullConsumerName, CancellationToken cancellationToken)
        {
            var queueName = GetQueueName(consumer.MessageBusConsumerEnum);

            using (var model = _rabbitConnection.CreateModel())
            {
                // Configure the Quality of service for the model. Below is how what each setting means.
                // BasicQos(0="Don't send me a new message until I’ve finished",  _fetchSize = "Send me N messages at a time", false ="Apply to this Model only")
                model.BasicQos(0, consumer.FetchCount.Value, false);
                var queueingConsumer = new QueueingBasicConsumer(model);

                model.BasicConsume(queueName, false, fullConsumerName, queueingConsumer);


                var queueEmpty = new BasicDeliverEventArgs(); //This is what gets returned if nothing in the queue is found.

                while (!cancellationToken.IsCancellationRequested)
                {
                    var deliverEventArgs = queueingConsumer.Queue.DequeueNoWait(queueEmpty);
                    if (deliverEventArgs == queueEmpty)
                    {
                        // This 100ms wait allows the processor to go do other work.
                        // No sense in going back to an empty queue immediately. 
                        // CancellationToken intentionally not used!
                        // ReSharper disable once MethodSupportsCancellation
                        await Task.Delay(100);  
                        continue;
                    }
                    //DO YOUR WORK HERE!
                  }
}

Source: stackoverflow.com

Similar codes

0 vote212 views1 answer
Polymorphism in C#
C#
0 vote213 views3 answers
Assets\PlayerMovement.cs(5,44): error CS1003: Syntax error, ',' expected
C#
1 vote201 views1 answer
Get current directory cosmos
C#
0 vote219 views1 answer
Filling a DataSet or a DataTable from a LINQ query result set C#
C#
0 vote217 views1 answer
Delay seconds in unity
C#
-11 votes217 views9 answers
çeviri
C#
34 votes197 views2 answers
Open scene unity
C#
0 vote234 views1 answer
Delay seconds in unity
C#Unity
0 vote215 views4 answers
Enum in c#
C#
0 vote219 views1 answer
Unable to resolve service for type 'Microsoft.AspNetCore.Identity.RoleManager`1[Microsoft.AspNetCore.Identity.IdentityRole]' while attempting to activate 'PathApp.Controllers.SearchPathController'.
C#