using System;
	  using Org.Apache.Qpid.Messaging;  (1)

	  namespace Org.Apache.Qpid.Messaging {
	  class Program {
	  static void Main(string[] args) {
	  String broker = args.Length > 0 ? args[0] : "localhost:5672";
	  String address = args.Length > 1 ? args[1] : "amq.topic";

	  Connection connection = null;
	  try {
	  connection = new Connection(broker);
	  connection.Open();   (2)
	  Session session = connection.CreateSession();   (3)

	  Receiver receiver = session.CreateReceiver(address);   (4)
	  Sender sender = session.CreateSender(address);   (5)

	  sender.Send(new Message("Hello world!"));

	  Message message = new Message();
	  message = receiver.Fetch(DurationConstants.SECOND * 1);   (6)
	  Console.WriteLine("{0}", message.GetContent());
	  session.Acknowledge();   (7)

	  connection.Close();   (8)
	  } catch (Exception e) {
	  Console.WriteLine("Exception {0}.", e);
	  if (null != connection)
	  connection.Close();
	  }
	  }
	  }
	  }