we are using azure-service-bus for notification services. in azure portal., service bus topic has been created and message is available in topic. Iam trying to use REST API services to get the topic data. This is the code I have…
Hi I have a publisher and consumer The registration for the publisher seems very simple services.AddMassTransit(x => { x.SetKebabCaseEndpointNameFormatter(); x.UsingAzureServiceBus((context, cfg) => { cfg.Host(configInstance.AzureServiceBusSettings.Connectionstring); cfg.AutoStart = true; } ); }); The registration for the consumer looks like this services.AddMassTransit(x =>…
I am trying to automate the infrastructure of my application. As part of that, I am creating Service Bus related resources (Namespace, Topics, Subscriptions) only if they do not exist. My subscriptions will only have 1 rule. So every time…
I have a simple Spring Cloud Azure Service Bus consumer defined as simply as follows, following the official documentation: @Bean public Consumer<Message<byte[]>> consume() { return message -> someProcessing(message); } The default policy, if the spring.cloud.stream.servicebus.bindings.consume-in-0.consumer.requeue-rejected flag is false, is that…
I use Azure Service Bus Queues to collect messages that need to be posted to an API. I'm using an Azure trigger function on the Queue to process incoming messages. Unfortunately, the API is unreliable so I'm working on adding…
According to Microsoft Docs: Auto-delete on idle enables you to specify an idle interval after which a queue or topic subscription is automatically deleted. The interval is reset when there is traffic on the entity. The minimum duration is 5…
Background - I'm creating and placing messages on an Azure Service Bus queue and processing the messages using IHostedService. Question - Is there any way I can create a delay in my IHostedService MessageHandler method to not process messages immediately…
I have a Kubernetes app that is constantly logging ServiceBusReceiver.Receive Dependency calls. It is creating 2000 logs per hour, per instance. In the TelemtryClient there are only custom methods for TrackEvent and TrackException so these look like they are coming…
Short summary When I deploy my application which uses Managed Identity to connect to the Service Bus instance, for a first couple of minutes I see a lot of Azure.Identity.CredentialUnavailableException exceptions in the logs. Then it all starts working fine…
What I want to Achieve - Azure Service Bus Message Listener to start / stop receiving messages from queue/topic. Below is a detailed explanation. Currently I have integrated Azure Service Bus in my application and we listen message as soon…