"Hello, World!" Sample Walkthrough

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;

using com.b2bits.FIXAntenna;

namespace HelloWorld.Initiator
{
    class Program
    {
        static bool loggedIn = false;

        static void Main(string[] args)
        {
            Console.WriteLine("HelloWorld sample, Initiator. (c) B2BITS 2009");
            try
            {
                FixEngine.Create("engine.properties");  // engine initialization

                string sender = "HelloWorldInitiator";  //sender and receiver can be any unique strings that will identify the session
                string target = "HelloWorldAcceptor";
                string host = "localhost";     // remote FIX engine's host name
                int heartBtInt = 30;           // Heartbeat interval (in seconds)
                int port = 9115;   //this should match port defined in ListenPort setting in engine.properties file in the Acceptor application

                //sessions are disposable objects, so we will create one in a using {} block 
                using (Session initiator = FixEngine.Instance.CreateSession(target, sender, FixVersion.FIX44))
                {
                    //subscribe for logon and logout events
                    initiator.LogonEvent += new Session.LogonEventHandler(initiator_LogonEvent);
                    initiator.LogoutEvent += new Session.LogoutEventHandler(initiator_LogoutEvent);

                    Console.WriteLine("Waiting for another side to create an acceptor session.");

                    do
                    {
                        try
                        {
                            initiator.ConnectAsInitiator(host, port, heartBtInt);
                        }
                        catch (ApplicationException)
                        {
                            //In the case when acceptor has not been started yet to the moment, 
                            //when initiator.ConnectAsInitiator executed
                            //FixEngine will raise and exception
                            // 
                            //We will ignore this exception and will try to connect again each second.
                        }
                        Thread.Sleep(1000);
                    }
                    while (!loggedIn);

                    //let's create a new order message
                    FixMessage msg = FixMessage.Create(FixVersion.FIX44, "D");
                    //it will be very simple message with "Hello, World!" string, that we will put in the Text tag
                    msg.SetField(Tag.Text, "Hello, World!");
                    msg.SetField(Tag.TransactTime, DateTime.Now.ToUniversalTime().ToString());

                    Console.WriteLine("Sending the message: {0}", msg.ToString('|'));

                    //Put method works asyncroneously
                    //It means that it will return immediately, when message is put to the queue but not send actually
                    initiator.Put(msg);
                    Console.WriteLine("Message was sent");

                    //Here we should wait while message will be actually sent and received through sockets
                    //and while acceptor will logout
                    //If we logout from initiator immediately after Put(), chances are that acceptor will not get the message

                    Console.WriteLine("Waiting while acceptor will disconnect");

                    do
                    {
                        //We wrote this loop only for a simplicity of the sample
                        //in real projects we do recomment to use synchronization classes from the System.Threading namespace
                        //like WaitHandle and classes inherited from it. Please, see HelloWorld.Acceptor for an example.
                        Thread.Sleep(100);
                    }
                    while (loggedIn);

                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }
            finally
            {
                FixEngine.Instance.Stop();
            }
            Console.WriteLine("Press a key to exit");
            Console.ReadKey();
        }

        static void initiator_LogonEvent(object sender, Session.LogonEventArgs args)
        {
            loggedIn = true;
            Console.WriteLine("Logged in.");
        }

        static void  initiator_LogoutEvent(object sender, Session.LogoutEventArgs args)
        {
            loggedIn = false;
            Console.WriteLine("Logged out.");
        }
    }
}

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;

using com.b2bits.FIXAntenna;

namespace HelloWorld.Acceptor
{
        class Program
    {
        static ManualResetEvent loggedInEvent = new ManualResetEvent(false);
        static ManualResetEvent messageReceivedEvent = new ManualResetEvent(false);

        static void Main(string[] args)
        {
            Console.WriteLine("HelloWorld sample, Acceptor. (c) B2BITS 2009");

            try
            {
                FixEngine.Create("engine.properties");  // engine initialization

                string sender = "HelloWorldAcceptor";  //sender and receiver can be any unique strings that will identify the session
                string target = "HelloWorldInitiator";

                //sessions are disposable objects, so we will create one in a using {} block 
                using (Session acceptor = FixEngine.Instance.CreateSession(target, sender, FixVersion.FIX44))
                {
                    //Subscribe for logon and IncomingMessageEvent events
                    //These events together with ManualResetEvent handlers 
                    //will be used to signal to the main thread that certain event occured
                    acceptor.LogonEvent += new Session.LogonEventHandler(acceptor_LogonEvent);
                    acceptor.IncomingMessageEvent += new Session.IncomingMessageEventHandler(acceptor_IncomingMessageEvent);

                    acceptor.ConnectAsAcceptor();

                    Console.WriteLine("Waiting for another side to create an initiator session.");
                    //stop the main thread and wait for Login event
                    loggedInEvent.WaitOne();

                    Console.WriteLine("Waiting for a message.");
                    //stop the main thread and wait for any message
                    messageReceivedEvent.WaitOne();

                    //When you call Disconnect, FixAntenna doesn't wait until all messages that are still in the queue will be processed 
                    //It will disconnect immediately.
                    //So it is important to Disconnect() only when you are sure that all expected messages have been already received
                    acceptor.Disconnect();
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }
            finally
            {
                FixEngine.Instance.Stop();
            }

            Console.WriteLine("Press a key to exit");
            Console.ReadKey();
        }

        static void  acceptor_IncomingMessageEvent(object sender, Session.IncomingMessageEventArgs args)
        {
             Console.WriteLine("Received incoming message: {0}",args.IncomingMessageMsg.ToString('|'));
            Console.WriteLine();

            //let's print the information from the Text tag
            Console.WriteLine(args.IncomingMessageMsg.GetAsString(Tag.Text));
            Console.WriteLine();

            //signal that the main program can proceed
            messageReceivedEvent.Set();
        }

        static void acceptor_LogonEvent(object sender, Session.LogonEventArgs args)
        {
            Console.WriteLine("Logged in.");
            //signal that the main program can proceed
            loggedInEvent.Set();
        }
    }
}