Step 2: Write Your First Program

 

Applies To: Service Bus for Windows Server 1.1

Write your first program

1. In Solution Explorer, double-click Program.cs to open it in the Visual Studio editor. Add the following using statements at the top of the file to include the namespaces for the model you just created, as well as for Service Bus:

   using System;
   using Microsoft.ServiceBus;
   using Microsoft.ServiceBus.Messaging;
   

   Obtain a Service Bus connection string from standard input (alternatively, you can read it from a configuration file):

   string connectionString;
   Console.WriteLine("Enter Service Bus Connection string:\n");
   connectionString = Console.ReadLine();
   

   Create a NamespaceManager instance (for management operations) and a MessagingFactory instance (for sending and receiving messages):

   MessagingFactory messageFactory = MessagingFactory.CreateFromConnectionString(connectionString);
   NamespaceManager namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString);
   

2. With the newly-created URI and token, create a new queue:

   using Microsoft.ServiceBus;
   using Microsoft.ServiceBus.Messaging;
   

3. With the newly-created URI and token, create a new queue:

   const string QueueName = "ServiceBusQueueSample";
   
   if (namespaceManager == null)
   {
       Console.WriteLine("\nUnexpected Error: NamespaceManager is NULL");
       return;
   }
   
   if (namespaceManager.QueueExists(QueueName))
   {
       namespaceManager.DeleteQueue(QueueName);
   }
   namespaceManager.CreateQueue(QueueName);
   

4. Create a queue client to send and receive messages to and from the queue:

   QueueClient myQueueClient = messageFactory.CreateQueueClient(QueueName);
   

5. Create a simple brokered message and send it to the queue:

   BrokeredMessage sendMessage = new BrokeredMessage("Hello World !");
   myQueueClient.Send(sendMessage);
   

6. Receive the message from the queue:

   BrokeredMessage receivedMessage = myQueueClient.Receive(TimeSpan.FromSeconds(5));
   
   if (receivedMessage != null)
   {
       Console.WriteLine(string.Format("Message received: Body = {0}", receivedMessage.GetBody<string>()));
       receivedMessage.Complete();
   }
   

7. Close the connection to Service Bus.

   if (messageFactory != null)                    
   {
       messageFactory.Close();
   }
   

The following is the complete Program.cs file as it should appear after following the previous steps:

namespace Microsoft.Samples.QueuesOnPrem
{
    using System;
    using Microsoft.ServiceBus;
    using Microsoft.ServiceBus.Messaging;

    public class Sender
    {
        static string ServerFQDN;
        static int HttpPort = 9355;
        static int TcpPort = 9354;
        static string ServiceNamespace = "ServiceBusDefaultNamespace";


        static void Main(string[] args)
        {
            ServerFQDN = System.Net.Dns.GetHostEntry(string.Empty).HostName;

            ServiceBusConnectionStringBuilder connBuilder = new ServiceBusConnectionStringBuilder();
            connBuilder.ManagementPort = HttpPort;
            connBuilder.RuntimePort = TcpPort;
            connBuilder.Endpoints.Add(new UriBuilder() { Scheme = "sb", Host = ServerFQDN, Path = ServiceNamespace }.Uri);
            connBuilder.StsEndpoints.Add(new UriBuilder() { Scheme = "https", Host = ServerFQDN, Port = HttpPort, Path = ServiceNamespace }.Uri);

            MessagingFactory messageFactory = MessagingFactory.CreateFromConnectionString(connBuilder.ToString());
            NamespaceManager namespaceManager = NamespaceManager.CreateFromConnectionString(connBuilder.ToString());

            if (namespaceManager == null)
            {
                Console.WriteLine("\nUnexpected Error");
                return;
            }

            string QueueName = "ServiceBusQueueSample";
            if (namespaceManager.QueueExists(QueueName))
            {
                namespaceManager.DeleteQueue(QueueName);
            }
            namespaceManager.CreateQueue(QueueName);

            QueueClient myQueueClient = messageFactory.CreateQueueClient(QueueName);

            try
            {
                BrokeredMessage sendMessage = new BrokeredMessage("Hello World !");
                myQueueClient.Send(sendMessage);

                // Receive the message from the queue
                BrokeredMessage receivedMessage = myQueueClient.Receive(TimeSpan.FromSeconds(5));

                if (receivedMessage != null)
                {
                    Console.WriteLine(string.Format("Message received: {0}", receivedMessage.GetBody<string>()));
                    receivedMessage.Complete();
                }
            }
            catch (Exception e)
            {
                Console.WriteLine("Unexpected exception {0}", e.ToString());
                throw;
            }
            finally
            {                
                if (messageFactory != null)
                    messageFactory.Close();
            }
            Console.WriteLine("Press  ENTER to clean up and exit.");
            Console.ReadLine();
        }
    }
}