Danthar

var dataArguments = ['args1','arg2','arg3','arg4'];

var bucket =[];

$.when.apply($,$.map(dataArguments, function(arg){
    
    //here you setup and return an ajax request
    //for example
    var ajaxData = {term:arg, somethingelse:0};
    return $.ajax({

Danthar

            system = ActorSystem.Create("myAkkaSystem");

            var coordinator = system.ActorOf<WorkCoordinatorActor>("workcoordinator");

            bus = RabbitHutch.CreateBus("host=localhost");
            bus.Subscribe<CdrRecieved>("<mysubId>", message => {
               
                    var result = coordinator.Ask<WorkCompleted>(new StartWorkFor() {Details = message}).Result;
                    //do something with it
            });

Danthar

coordinatorActor.Ask<string>(new JuleeDoTheThing());

//meanwhile in the coordinatorActor..

//..

Receive<JuleeDoTheThing>(message => {
    _askParent = Context.Sender;
    childActor.Tell(new DoSomething());

Danthar

using System;
using Akka.Actor;

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

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...

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

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

 
//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

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

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

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