Danthar

public static class SerializerTestHelpers
    {
        public static async Task<T> AkkaSerialized<T>(this T src)
        {
            var hocon = "akka.actor.provider = \"Akka.Remote.RemoteActorRefProvider, Akka.Remote\"" +
                        Environment.NewLine +
                        "akka.remote.helios.tcp.port = 0" + Environment.NewLine +
                        "akka.remote.helios.tcp.hostname = localhost";
            var sys = ActorSystem.Create("src");//, ConfigurationFactory.ParseString(hokon));
            await sys.Terminate();

Danthar

<?xml version="1.0" encoding="utf-8"?>
<configuration>
  <configSections>
    <section name="akka" type="Akka.Configuration.Hocon.AkkaConfigurationSection, Akka"/>
  </configSections>

  <akka>
    <hocon>
      akka {
      stdout-loglevel = DEBUG

Danthar

$(function () {
    $('span.field-validation-valid, span.field-validation-error').each(function () {
        $(this).addClass('help-block col-xs-12 col-sm-reset inline');
    });

    $('.validation-summary-errors').each(function () {
        $(this).addClass('alert');
        $(this).addClass('alert-error');
        $(this).addClass('alert-block');

Danthar

class AskAggregator<TReq, TRep> : ReceiveActor
{
    public AskAggregator(IActorRef askFor, IActorRef replyTo, IEnumerable<TReq> items)
    {
        var requestCount = items.Count();
        var replies = new HashSet<TRep>();

        foreach (var request in items) 
            askFor.Tell(request);

Danthar

2015-07-08 14:10:41.588 +02:00 [Information] "Message DeathWatchNotification from akka://Importer/user/stamdata/importRouter/$b/processor to akka://Importer/user/stamdata/importRouter/$b/processor was not delivered. 1 dead letters encountered."
2015-07-08 14:10:41.589 +02:00 [Information] "Message DeathWatchNotification from akka://Importer/user/stamdata/importRouter/$b to akka://Importer/user/stamdata/importRouter/$b was not delivered. 2 dead letters encountered."
2015-07-08 14:10:41.589 +02:00 [Information] "Message DeathWatchNotification from akka://Importer/user/stamdata/importRouter/$b/processor/database to akka://Importer/user/stamdata/importRouter/$b/processor/database was not delivered. 3 dead letters encountered."
2015-07-08 14:10:41.590 +02:00 [Information] "Message DeathWatchNotification from akka://Importer/user/stamdata/importRouter/$b to akka://Importer/user/stamdata/importRouter/$b was not delivered. 4 dead letters encountered."
2015-07-08 14:10:41.591 +02:00 [Information] "Message DeathWatchNo

Danthar

using System;
using Akka.Actor;
using Akka.Routing;

namespace Akka.RouterStrategies
{
    class Program
    {
        static void Main(string[] args) {
            var system = ActorSystem.Create("failboat");

Danthar

 
//Usefull for consumer/producer processing where you keep track of how many work you have served up in the producer
//and call Wait with that amount
//then consumer will call Hit to signal some work has been completed.
//producer will block on Wait until consumer has catched up
 public class Throttler {
        private AutoResetEvent resetEvent = new AutoResetEvent(false);
        private int counter;

        private int throttleAmount;

Danthar

public class WerkbonAggregate {
    
    private WerkbonModel _state;
    private List<object> _uncommittedEvents = new List<object>();
    
    public WerkbonAggregate(WerkbonModel state) {
      _state = state;
    }
    
    public void StartWerkzaamHeden(DateTime gestartOp){

Danthar

class Program
    {
        static void Main(string[] args) {
            var system = ActorSystem.Create("failboat");

            var actor = system.ActorOf(Props.Create(() => new ParentActor()));

            actor.Tell(5); //this will fail

            actor.Tell("This message will work");

Danthar

//this is with the easynetq librabry but could just as easily be anything else.

rabbitBus.Subscribe<MyMessageType>(subscriptionId, message => {
      Log.Debug("message from rabbitmq received");
      
      //this works! because of how Ask works (it creates a fake actor that is passed as sender behind the scenes)
      var result = workers.Ask<WorkCompleted>(new StartWorkFor() {Details = message}).Result;
  });

//however this...