Azure Service Bus

venkatesh chava

I just Want to send a message to Azure Service Bus With delayed process at particular time eg: after 2 hrs . how i can archive that please povide me an example. Thanks in advance.

So far i did like this but i am unable send the message to queue. i am getting status as Faulted.

public class ServiceBusQueueHelpers

{

string serviceBusConnectionString = "my Queue Connectionstring";

string sbQueueName = "Test Queue";

DateTime utcEnqueueTime = DateTime.UtcNow;

public static Microsoft.Azure.ServiceBus.QueueClient queueClient;

public async Task SendDelayedMessageAsync(string queue, string message, string serviceBusConnectionString, DateTime utcEnqueueTime)

{

ServiceBusConnectionStringBuilder sb = new ServiceBusConnectionStringBuilder(serviceBusConnectionString);

for (int i = 0; i < 2; i++)

{

Message queueMessage = new Message(Encoding.UTF8.GetBytes(message));

queueMessage.ScheduledEnqueueTimeUtc = utcEnqueueTime.AddSeconds(120);

Microsoft.Azure.ServiceBus.QueueClient client = new Microsoft.Azure.ServiceBus.QueueClient(sb, Microsoft.Azure.ServiceBus.ReceiveMode.ReceiveAndDelete);

await client.SendAsync(queueMessage);

await client.CloseAsync();

}

2 Replies

Know the answer? Post it — somebody with the same question will find it here.

Ravishankar N7y ago
Hi Venkatesh

You can schedule messages either by setting the ScheduledEnqueueTimeUtc property when sending a message through the regular send path, or explicitly with the ScheduleMessageAsync API. The latter immediately returns the scheduled message's SequenceNumber, which you can later use to cancel the scheduled message if needed. Scheduled messages and their sequence numbers can also be discovered using message browsing.

https://docs.microsoft.com/en-us/dotnet/api/microsoft.azure.servicebus.queueclient.schedulemessageasync?view=azure-dotnet#Microsoft_Azure_ServiceBus_QueueClient_ScheduleMessageAsync_Microsoft_Azure_ServiceBus_Message_System_DateTimeOffset_
Madan Shekar7y ago
your queue name should be in lowercase.
https://docs.microsoft.com/en-us/rest/api/storageservices/naming-queues-and-metadata

fix this one run one more time in case of issue . please let me know.

keep your code in side try and catch block, so that you can find out something