using System;

using Akka.Configuration;

using Akka.Actor;

using System.Threading;

​

public class Greet

{

    public Greet(string who)

    {

        Who = who;

    }

    public string Who { get;private set; }

}

​

public class MyTimeOut

{

​

}

​

public class CancelTimeOut

{

}

​

public class GreetingActor : ReceiveActor

{

    private ICancelable cancel;

    public GreetingActor()

    {

        cancel = Context.System.Scheduler.ScheduleTellOnceCancelable( TimeSpan.FromSeconds(2), Self, new MyTimeOut(), Self);

        Receive<Greet>(greet => 

                       {

                           Console.WriteLine("Hello {0} {1}", greet.Who, DateTime.Now);

                       });

        Receive<MyTimeOut>( _ => Console.WriteLine("TimeOut"));

        Receive<CancelTimeOut>( _ => 

                               {

                                   cancel.Cancel();

                                   Console.WriteLine("Cancel");

                               });

    }

}

​

public class Program

{

    public static void Main()

    {

        var config = ConfigurationFactory.ParseString(@"akka.actor.default-dispatcher { type = ""Akka.Dispatch.TaskDispatcherConfigurator""}");

        var system = ActorSystem.Create("Sample", config);

        //create your actor and get a reference to it.

        //this will be an "ActorRef", which is not a reference to the actual actor instance

        //but rather a client or proxy to it

        var greeter = system.ActorOf<GreetingActor>("greeter");

        //send a message to the actor

        greeter.Tell(new Greet("World"));   

        //greeter.Tell(new CancelTimeOut());

        Thread.Sleep(4000);

        //system.AwaitTermination();

    }

}

​