Switch between job schedulers

using System;
using AGI.Parallel.Client;
using AGI.Parallel.Infrastructure;

namespace CodeSamples
{
    class Program
    {
        static void Main(string[] args)
        {
            using (IJobScheduler scheduler = GetJobScheduler(args))
            {
                scheduler.Connect();

                // If you need to... you can also try to upcast to ClusterJobScheduler
                ClusterJobScheduler asClusterScheduler = scheduler as ClusterJobScheduler;
                if (asClusterScheduler != null)
                {
                    Console.WriteLine("We are using the cluster scheduler");
                }
            }
        }

        // In your factory method, return the IJobScheduler.
        private static IJobScheduler GetJobScheduler(string[] args)
        {
            if (args.Length > 0 && args[0] == "local")
            {
                return GetEmbeddedJobScheduler();
            }
            else
            {
                return GetClusterJobScheduler();
            }
        }

        private static IJobScheduler GetEmbeddedJobScheduler()
        {
            return new EmbeddedJobScheduler();
        }

        private static IJobScheduler GetClusterJobScheduler()
        {
            return new ClusterJobScheduler("localhost");
        }
    }
}