AipGateway/NamedPipeExample/QueueWriter.Console/Program.cs

using Dto;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Messaging;
using System.Text;
using System.Threading.Tasks;

namespace QueueWriter.Console
{
    class Program
    {
        static void Main(string[] args)
        {
            GatherAndSend();
        }

        private static void GatherAndSend()
        {
            System.Console.WriteLine("type some stuff to queue up");
            var input = System.Console.ReadLine();


            using (var mq = new MessageQueue(ConfigurationManager.AppSettings["OperationMessageQueuePath"]))
            {
                var qItem = new QueuedWorkItem() { Name = input };
                using (var msg = new System.Messaging.Message(qItem))
                {
                    msg.Label = "Queued Item from the console";
                    msg.Formatter = new XmlMessageFormatter(new Type[] { typeof(QueuedWorkItem) });
                    mq.Send(msg);
                    System.Console.WriteLine("Message sent. Message ID is {0}", msg.Id);
                }
            }

            System.Console.WriteLine("write another message to the queue? Y/N");
            var decision = System.Console.ReadLine();

            if (decision == "y")
            { GatherAndSend(); }

        }
    }
}