Sending a message to a Azure Service Bus queue using .Net Framework .4.5.2

1
votes

I am currently trying to send a message to an Azure Service Bus queue and seem always to run into errors.

Here is my example. 

namespace azure_queue
{
    class sendtoAzure
    {    
        public  async Task sendAsync(string message)
        {
            const string ServiceBusConnectString = "<connection-string>";
            const string QueueName = "<QueueName>";
            var AzureClient = Microsoft.ServiceBus.Messaging.QueueClient.CreateFromConnectionString(ServiceBusConnectString, QueueName);
            await AzureClient.SendAsync(new Microsoft.ServiceBus.Messaging.BrokeredMessage(message));
        }
    }
    class Program
    {

        static void Main(string[] args)
        {

            string transferObject_string = "This is a test";
            Microsoft.ServiceBus.Messaging.BrokeredMessage message = new Microsoft.ServiceBus.Messaging.BrokeredMessage(transferObject_string);
            Console.WriteLine("Sending message to azure");
            sendtoAzure client = new sendtoAzure();

            try
            {

                client.sendAsync(transferObject_string).Wait(TimeSpan.FromSeconds(60));
            }
            catch (System.Exception ex)
            {
                Console.WriteLine("Exception: " + ex.StackTrace);
                Console.WriteLine("Message: " + ex.Message);
                Console.WriteLine("HelpLink: " + ex.HelpLink);
                Console.WriteLine("Source: " + ex.Source);
                Console.ReadLine();

                if (ex is System.TimeoutException)
                {
                    Console.WriteLine("Timeout exeption");
                }

                if (ex is System.ArgumentException)
                {
                    Console.WriteLine("Message is empty");
                }

                if (ex is System.UnauthorizedAccessException)
                {
                    Console.WriteLine("Unauthorized access!");
                }

                if (ex is Microsoft.ServiceBus.Messaging.SessionCannotBeLockedException)
                {
                    Console.WriteLine("Attempt to accept a session with a specific session ID, but the session is currently locked by another client.");
                }
            }
        Console.WriteLine("Message Sent!");
            Console.ReadLine();


        }
    }
}

And the error message I am getting is: 

Sending message to azure
Exception:    at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean includeTaskCanceledExceptions)
   at System.Threading.Tasks.Task.Wait(Int32 millisecondsTimeout, CancellationToken cancellationToken)
   at System.Threading.Tasks.Task.Wait()
   at azure_queue.Program.Main(String[] args) in C:\Users\keer\Source\Repos\azure_queue\azure_queue\Program.cs:line 39
Message: One or more errors occurred.
HelpLink:
Source: mscorlib

Message Sent!

I tried without async aswell, and that work, but nothing seem to enter the queue, when I check the portal. What Coul this error be caused by?

The same example just with send

example: 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.ServiceBus;
using System.Configuration;
using System.Messaging;
using System.ServiceModel;
using System.Net;


namespace azure_queue
{
    public class sendtoAzure
    {
        public string ServiceBusConnectString;
        public string QueueName;
        public Microsoft.ServiceBus.Messaging.QueueClient AzureClient;

        public sendtoAzure()
        {
            ServiceBusConnectString = "<connectionstring>";
            QueueName = "<Queue-name>";
            AzureClient = Microsoft.ServiceBus.Messaging.QueueClient.CreateFromConnectionString(ServiceBusConnectString, QueueName);
        }

        public void send (string message)
        { 
            AzureClient.Send(new Microsoft.ServiceBus.Messaging.BrokeredMessage(message));
        }
    }
    class Program
    {

        static void Main(string[] args)
        {

            string transferObject_string = "This is a test";
            Microsoft.ServiceBus.Messaging.BrokeredMessage message = new Microsoft.ServiceBus.Messaging.BrokeredMessage(transferObject_string);
            Console.WriteLine("Sending message to azure");
            sendtoAzure client = new sendtoAzure();
            try
            {
                client.send(transferObject_string);
            }
            catch (System.Exception ex)
            {
                Console.WriteLine("Exception: " + ex.StackTrace);
                Console.WriteLine("Message: " + ex.Message);
                Console.WriteLine("HelpLink: " + ex.HelpLink);
                Console.WriteLine("Source: " + ex.Source);
                Console.WriteLine("InnerExeption: " + ex.InnerException);

                Console.ReadLine();

                if (ex is System.TimeoutException)
                {
                    Console.WriteLine("Timeout exeption");
                }

                if (ex is System.ArgumentException)
                {
                    Console.WriteLine("Message is empty");
                }

                if (ex is System.UnauthorizedAccessException)
                {
                    Console.WriteLine("Unauthorized access!");
                }

                if (ex is Microsoft.ServiceBus.Messaging.SessionCannotBeLockedException)
                {
                    Console.WriteLine("Attempt to accept a session with a specific session ID, but the session is currently locked by another client.");
                }
            }
            Console.WriteLine("Message Sent!");
            Console.ReadLine();

        }
    }
}

Gives this erro - including innner execption: 

Sending message to azure
Exception:    at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.RunSynchronously()
   at Microsoft.ServiceBus.Messaging.MessageSender.OnSend(TrackingContext trackingContext, IEnumerable`1 messages, TimeSpan timeout)
   at Microsoft.ServiceBus.Messaging.MessageSender.Send(TrackingContext trackingContext, IEnumerable`1 messages, TimeSpan timeout)
   at Microsoft.ServiceBus.Messaging.MessageSender.Send(BrokeredMessage message)
   at Microsoft.ServiceBus.Messaging.QueueClient.Send(BrokeredMessage message)
   at azure_queue.sendtoAzure.send(String message) in C:\Users\keer\Source\Repos\azure_queue\azure_queue\Program.cs:line 30
   at azure_queue.Program.Main(String[] args) in C:\Users\keer\Source\Repos\azure_queue\azure_queue\Program.cs:line 45
Message: 40400: Endpoint not found., Resource:sb://x-shared.servicebus.windows.net/x%20-%20test. TrackingId:fd30b288-cc6a-4360-9922-0b044e9de8f4_G28, SystemTracker:x-shared.servicebus.windows.net:x%20-%20test, Timestamp:6/28/2018 1:57:25 PM
HelpLink:
Source: Microsoft.ServiceBus
InnerExeption: System.ServiceModel.FaultException: 40400: Endpoint not found., Resource:sb://x-shared.servicebus.windows.net/x%20-%20test. TrackingId:fd30b288-cc6a-4360-9922-0b044e9de8f4_G28, SystemTracker:x-shared.servicebus.windows.net:x%20-%20test, Timestamp:6/28/2018 1:57:25 PM
   at Microsoft.ServiceBus.Messaging.Sbmp.DuplexRequestBindingElement.DuplexRequestSessionChannel.ThrowIfFaultMessage(Message wcfMessage)
   at Microsoft.ServiceBus.Messaging.Sbmp.DuplexRequestBindingElement.DuplexRequestSessionChannel.HandleMessageReceived(IAsyncResult result)
--- End of stack trace from previous location where exception was thrown ---
   at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.Sbmp.DuplexRequestBindingElement.DuplexRequestSessionChannel.EndRequest(IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.Channels.ReconnectBindingElement.ReconnectChannelFactory`1.RequestSessionChannel.RequestAsyncResult.<>c.<GetAsyncSteps>b__9_3(RequestAsyncResult thisPtr, IAsyncResult r)
   at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.StepCallback(IAsyncResult result)
--- End of stack trace from previous location where exception was thrown ---
   at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result)
   at Microsoft.ServiceBus.Common.AsyncResult`1.End(IAsyncResult asyncResult)
   at Microsoft.ServiceBus.Messaging.Channels.ReconnectBindingElement.ReconnectChannelFactory`1.RequestSessionChannel.EndRequest(IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.Sbmp.RedirectBindingElement.RedirectContainerChannelFactory`1.RedirectContainerSessionChannel.RequestAsyncResult.<>c__DisplayClass8_1.<GetAsyncSteps>b__4(RequestAsyncResult thisPtr, IAsyncResult r)
   at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.StepCallback(IAsyncResult result)
--- End of stack trace from previous location where exception was thrown ---
   at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result)
   at Microsoft.ServiceBus.Common.AsyncResult`1.End(IAsyncResult asyncResult)
   at Microsoft.ServiceBus.Messaging.Sbmp.RedirectBindingElement.RedirectContainerChannelFactory`1.RedirectContainerSessionChannel.EndRequest(IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.Channels.ReconnectBindingElement.ReconnectChannelFactory`1.RequestSessionChannel.RequestAsyncResult.<>c.<GetAsyncSteps>b__9_3(RequestAsyncResult thisPtr, IAsyncResult r)
   at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.StepCallback(IAsyncResult result)
--- End of stack trace from previous location where exception was thrown ---
   at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result)
   at Microsoft.ServiceBus.Common.AsyncResult`1.End(IAsyncResult asyncResult)
   at Microsoft.ServiceBus.Messaging.Channels.ReconnectBindingElement.ReconnectChannelFactory`1.RequestSessionChannel.EndRequest(IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.Sbmp.SbmpTransactionalAsyncResult`1.<>c.<GetAsyncSteps>b__18_3(TIteratorAsyncResult thisPtr, IAsyncResult a)
   at Microsoft.ServiceBus.Messaging.IteratorAsyncResult`1.StepCallback(IAsyncResult result)
--- End of stack trace from previous location where exception was thrown ---
   at Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result)
   at Microsoft.ServiceBus.Messaging.Sbmp.SbmpMessageSender.EndSendCommand(IAsyncResult result)
2
c#azureazureservicebusazure-servicebus-queues
You have to await the call to your sendAsync method.. Are saying that when using the synchronous method you don't get an error, but you don't see the message in the queue? I suggest writing the whole exception to the console (ex.ToString()) in case there are any inner exceptions you're not seeing. – stuartd

2 Answers

0
votes

I was able to successfully send a brokered message using your sendAsync() method implementation.

In addition, I was able to reproduce the same error stated in your question when the queue DOES NOT exist (e.g. taskqueue1).

Message: 40400: Endpoint not found., Resource:sb://{valid service bus namespace}.servicebus.windows.net/taskqueue1. TrackingId:7ce43d17-d339-4ded-b3be-71364a64f685_G17, SystemTracker:{valid service bus namespace}.servicebus.windows.net:taskqueue1, Timestamp:7/1/2018 1:23:04 AM...

The queue name x%20-%20test in the endpoint extracted from exception you posted does not seem valid because of the whitespaces (e.g. %20).

sb://x-shared.servicebus.windows.net/x%20-%20test

So, please double check that the Azure Service Bus queue name is correct/valid and that it does exit.

Moreover, the Azure Service Bus FQDN that you're using is probably correct. Otherwise, the following exception will be thrown instead of the one described in your question:

Microsoft.ServiceBus.Messaging.MessagingCommunicationException: The remote name could not be resolved: '{nonexistent service bus namespace}.servicebus.windows.net'...
0
votes

Messages can be sent to Azure service Bus Queues as below

namespace ServiceBus_Queue { class Program { const string ServiceBusConnectionString = ""; const string QueueName = ""; static void Main(string[] args) { MainAsync().GetAwaiter().GetResult(); } static async Task MainAsync() { var queueClient = QueueClient.CreateFromConnectionString(ServiceBusConnectionString, QueueName); string Message = "I'm in Azure Service Bus Queue"; BrokeredMessage message = new BrokeredMessage(Message); await queueClient.SendAsync(message); } } }