annymsMthd

# Windows AMIs don't have WinRM enabled by default -- this script will enable WinRM
# AND install the CloudInit.NET service, 7-zip, curl and .NET 4 if its missing.
# Then use the EC2 tools to create a new AMI from the result, and you have a system 
# that will execute user-data as a PowerShell script after the instance fires up!
# This has been tested on Windows 2008 R2 Core x64 and Windows 2008 SP2 x86 AMIs provided
# by Amazon
# 
# To run the script, open up a PowerShell prompt as admin
# PS> Set-ExecutionPolicy Unrestricted
# PS> icm $executioncontext.InvokeCommand.NewScriptBlock((New-Object Net.WebClient).DownloadString('https://raw.github.com/gist/1672426/Bootstrap-EC2-Windows-CloudInit.ps1'))

annymsMthd

# Windows AMIs don't have WinRM enabled by default -- this script will enable WinRM
# AND install 7-zip, curl and .NET 4 if its missing.
# Then use the EC2 tools to create a new AMI from the result, and you have a system 
# that will execute user-data as a PowerShell script after the instance fires up!
# This has been tested on Windows 2008 SP2 64bits AMIs provided by Amazon
# 
# Inject this as user-data of a Windows 2008 AMI, like this (edit the adminPassword to your needs):
#
# <powershell>
# Set-ExecutionPolicy Unrestricted

annymsMthd

[INFO] [05/11/2015 10:06:38.239] [ClusterSystem-akka.actor.default-dispatcher-2] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2551] - Leader is moving node [akka.tcp://ClusterSystem@127.0.0.1:2555] to [Up]
[INFO] [05/11/2015 10:06:38.239] [ClusterSystem-akka.actor.default-dispatcher-16] [akka.tcp://ClusterSystem@127.0.0.1:2551/user/clusterListener] Member is Up: akka.tcp://ClusterSystem@127.0.0.1:2555
[WARN] [05/11/2015 10:06:52.329] [ClusterSystem-akka.remote.default-remote-dispatcher-35] [akka.tcp://ClusterSystem@127.0.0.1:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FClusterSystem%40127.0.0.1%3A2555-1] Association with remote system [akka.tcp://ClusterSystem@127.0.0.1:2555] has failed, address is now gated for [5000] ms. Reason: [Disassociated] 
[INFO] [05/11/2015 10:06:53.236] [ClusterSystem-akka.actor.default-dispatcher-16] [akka://ClusterSystem/deadLetters] Message [akka.cluster.GossipStatus] from Actor[akka://ClusterSystem/system/cl

annymsMthd

[INFO] [05/11/2015 10:35:32.385] [ClusterSystem-akka.actor.default-dispatcher-2] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2551] - Node [akka.tcp://ClusterSystem@127.0.0.1:2555] is JOINING, roles []
[INFO] [05/11/2015 10:35:33.259] [ClusterSystem-akka.actor.default-dispatcher-4] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2551] - Im the boss
[INFO] [05/11/2015 10:35:33.260] [ClusterSystem-akka.actor.default-dispatcher-4] [akka.cluster.Cluster(akka://ClusterSystem)] Cluster Node [akka.tcp://ClusterSystem@127.0.0.1:2551] - Leader is moving node [akka.tcp://ClusterSystem@127.0.0.1:2555] to [Up]
[INFO] [05/11/2015 10:35:33.260] [ClusterSystem-akka.actor.default-dispatcher-15] [akka.tcp://ClusterSystem@127.0.0.1:2551/user/clusterListener] Member is Up: akka.tcp://ClusterSystem@127.0.0.1:2555
[INFO] [05/11/2015 10:35:34.260] [ClusterSystem-akka.actor.default-dispatcher-17] [akka.cluster.Cluster(akka://ClusterSystem

annymsMthd

5/12/2015 9:55:54 AM	Info	ClusterCoreDaemon	9	Node [akka.tcp://ClusterSystem@172.16.1.34:8099] is JOINING, roles [arrivals]
5/12/2015 9:55:58 AM	Info	ClusterCoreDaemon	32	Leader is moving node [akka.tcp://ClusterSystem@172.16.1.34:8099] to [Up]
5/12/2015 9:56:22 AM	Warn	ClusterCoreDaemon	22	Cluster Node [akka.tcp://ClusterSystem@172.16.1.34:8091] - Marking node(s) as UNREACHABLE [Member(address = akka.tcp://ClusterSystem@172.16.1.34:8099, status = Up]
5/12/2015 9:56:29 AM	Error	ProtocolStateActor	122	No response from remote. Handshake timed out or transport failure detector triggered. 
5/12/2015 9:56:29 AM	Warn	ReliableDeliverySupervisor	122	Association with remote system akka.tcp://ClusterSystem@172.16.1.34:8099 has failed; address is now gated for 5000 ms. Reason is: [Disassociated]
5/12/2015 9:56:29 AM	Error	OneForOneStrategy	122	Disassociated Akka.Remote.EndpointDisassociatedException: Disassociated    at Akka.Remote.EndpointWriter.PublishAndThrow(Exception reason, LogLevel level) in c:\Users\benjamin\Doc

annymsMthd

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

namespace ThreadPoolTest
{
    class Program

annymsMthd

//-----------------------------------------------------------------------
// <copyright file="TaskBasedScheduler.cs" company="Akka.NET Project">
//     Copyright (C) 2009-2015 Typesafe Inc. <http://www.typesafe.com>
//     Copyright (C) 2013-2015 Akka.NET project <https://github.com/akkadotnet/akka.net>
// </copyright>
//-----------------------------------------------------------------------

using System;
using System.Threading;
using System.Threading.Tasks;

annymsMthd

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

namespace ThreadPoolTest
{
    class Program

annymsMthd

/// <summary>
    /// Class Scheduler.
    /// </summary>
    public class ThreadPoolBasedScheduler : SchedulerBase, IDateTimeOffsetNowTimeProvider
    {
        protected override DateTimeOffset TimeNow { get { return DateTimeOffset.Now; } }
        public override TimeSpan MonotonicClock { get { return Util.MonotonicClock.Elapsed; } }
        public override TimeSpan HighResMonotonicClock { get { return Util.MonotonicClock.ElapsedHighRes; } }

        protected override void InternalScheduleTellOnce(TimeSpan delay, ICanTell receiver, object message, IActorRef sender, ICancelable cancelable)

annymsMthd

//-----------------------------------------------------------------------
// <copyright file="Program.cs" company="Akka.NET Project">
//     Copyright (C) 2009-2015 Typesafe Inc. <http://www.typesafe.com>
//     Copyright (C) 2013-2015 Akka.NET project <https://github.com/akkadotnet/akka.net>
// </copyright>
//-----------------------------------------------------------------------

using System;
using System.Collections.Generic;
using System.Configuration;