using System;

using Akka;

using Akka.Actor;

using Akka.Configuration;

using System.Threading.Tasks;

​

public class Program

{

    public class Actor

    {

        public string Name { get; private set; }

​

        public Actor(string name)

        {

            Name = name;

        }

    }

​

    public class ShowName : ReceiveActor

    {

        public ShowName()

        {

            Receive<Actor>(actor => Console.WriteLine(actor.Name));

        }

​

        protected override void PostStop()

        {

            Console.WriteLine("Actor Stopped");

        }

​

        protected override void PreRestart(Exception reason, object message)

        {

            PostStop();

        }

    }

​

    public static void Main()

    {

        ActorSystem system = ActorSystem.Create("MySystem", GetConfig());

        var name = system.ActorOf(Props.Create<ShowName>());

        Actor act = new Actor("Actor Begining");

        name.Tell(act);

            Task.Delay(4000).Wait();

        system.Shutdown();

        Console.WriteLine("Actor Ended");

    }

​

    private static Config GetConfig()

    {

        return ConfigurationFactory.ParseString(@"

                    akka.actor.default-dispatcher {

                            type = ""Akka.Dispatch.TaskDispatcher""

                            throughput = 30

                        }");

    }

}