第 4 章 例子

using System;
using Apache.Qpid.Proton.Client;                                                        

namespace Apache.Qpid.Proton.Examples.HelloWorld
{
   class Program
   {
      private static readonly int MessageCount = 100;                                   

      static void Main(string[] args)
      {
         string serverHost =
            Environment.GetEnvironmentVariable("HOST") ?? "localhost";                  
         int serverPort =
            Convert.ToInt32(Environment.GetEnvironmentVariable("PORT") ?? "5672");      
         string address =
            Environment.GetEnvironmentVariable("ADDRESS") ?? "send-receive-example";

         IClient client = IClient.Create();                                             

         ConnectionOptions options = new ConnectionOptions();                           
         options.User = Environment.GetEnvironmentVariable("USER");
         options.Password = Environment.GetEnvironmentVariable("PASSWORD");

         using IConnection connection = client.Connect(serverHost, serverPort, options);
         using ISender sender = connection.OpenSender(address);                         

         for (int i = 0; i < MessageCount; ++i)
         {
            IMessage<string> message =
                IMessage<string>.Create(string.Format("Hello World! [{0}]", i));        
            ITracker tracker = sender.Send(message);                                    
            tracker.AwaitSettlement();                                                  

            Console.WriteLine(string.Format("Sent message to {0}: {1}",
                sender.Address, message.Body));
         }
      }
   }
}

using System;
using Apache.Qpid.Proton.Client;                                                        

namespace Apache.Qpid.Proton.Examples.HelloWorld
{
   class Program
   {
      private static readonly int MessageCount = 100;                                   

      static void Main(string[] args)
      {
         string serverHost =
            Environment.GetEnvironmentVariable("HOST") ?? "localhost";                  

         int serverPort =
            Convert.ToInt32(Environment.GetEnvironmentVariable("PORT") ?? "5672");      

         string address =
            Environment.GetEnvironmentVariable("ADDRESS") ?? "send-receive-example";

         IClient client = IClient.Create();                                             

         ConnectionOptions options = new ConnectionOptions();                           

         options.User = Environment.GetEnvironmentVariable("USER");
         options.Password = Environment.GetEnvironmentVariable("PASSWORD");

         using IConnection connection = client.Connect(serverHost, serverPort, options);

         using ISender sender = connection.OpenSender(address);                         

         for (int i = 0; i < MessageCount; ++i)
         {
            IMessage<string> message =
                IMessage<string>.Create(string.Format("Hello World! [{0}]", i));        

            ITracker tracker = sender.Send(message);                                    

            tracker.AwaitSettlement();                                                  

            Console.WriteLine(string.Format("Sent message to {0}: {1}",
                sender.Address, message.Body));
         }
      }
   }
}