Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Jan 28 22:17
    Aaronontheweb edited #4152
  • Jan 28 22:16
    Aaronontheweb milestoned #2750
  • Jan 28 22:16
    Aaronontheweb demilestoned #2750
  • Jan 28 22:15
    Aaronontheweb milestoned #4007
  • Jan 28 22:15
    Aaronontheweb demilestoned #4007
  • Jan 28 22:14
    Aaronontheweb synchronize #4086
  • Jan 28 21:49

    Aaronontheweb on 1.4.0-beta4

    (compare)

  • Jan 28 21:47

    Aaronontheweb on dev

    V1.4.0 beta4 release notes (#41… (compare)

  • Jan 28 21:47
    Aaronontheweb closed #4174
  • Jan 28 21:45

    Aaronontheweb on dev

    modified build script so if the… (compare)

  • Jan 28 21:45
    Aaronontheweb closed #4175
  • Jan 28 21:42
    Aaronontheweb labeled #4175
  • Jan 28 21:42
    Aaronontheweb opened #4175
  • Jan 28 21:02
    Aaronontheweb synchronize #4174
  • Jan 28 21:02
    Aaronontheweb opened #4174
  • Jan 28 20:47
    Aaronontheweb demilestoned #4096
  • Jan 28 20:47
    Aaronontheweb edited #4096
  • Jan 28 20:25

    Aaronontheweb on dev

    added real header to Akka.Remot… (compare)

  • Jan 28 20:25
    Aaronontheweb closed #4173
  • Jan 28 20:20
    Aaronontheweb labeled #4173
Birnsen
@Birnsen
@schatekar added html output. you can see some examples at https://github.com/Birnsen/MultiNodeVisualizer/tree/master/output
if you move your mouse over an item you see the corresponding message at that time. Let me know if you miss something...
Suhas Chatekar
@schatekar
@Birnsen this is good for starters. I would leave it to @Aaronontheweb to comment if this is in line with what he wanted.
Damian Reeves
@DamianReeves
@Horusiath is Oracle support planned for Akka.Persistence?
Roger Johansson
@rogeralsing
@rdavisau would you mind taking a peek at https://github.com/rogeralsing/Wire ? I've added tests for F# types and they all pass.. got a local branch of Akka.NET using Wire serializer and all serializer tests pass there too... looking good so far, but Im sure there are edgecases that I havent covered yet, both regardng F# and the normal type system
Ryan Davis
@rdavisau
@rogeralsing sure - I was out and about this weekend but did see your tweet - will run through some scenarios with it tomorrow!
btw well done, the performance results are impressive :+1:
Hyungho Ko
@hhko
ActorSystem.Shutdown() method is processing asynchronous. If a actor is processing, Is ActorSystem waiting until it is completed?
blob
class FooActor : UntypedActor
{
public FooActor()
{
Console.WriteLine("FooActor: ConstructorB");
}
    protected override void PreStart()
    {
        base.PreStart();
        Console.WriteLine("FooActor: PreStart");
    }

    protected override void PostStop()
    {
        base.PostStop();
        Console.WriteLine("FooActor: PostStop");
    }

    protected override void OnReceive(object message)
    {
        string number = (string)message;
        Console.WriteLine("FooActor: OnReceiving:\t {0}", number);
        Thread.Sleep(2000);
        Console.WriteLine("FooActor: OnReceived:\t {0}", number);
    }
}

class Program
{
    static void Main(string[] args)
    {
        using (ActorSystem system = ActorSystem.Create("BLUE"))
        {
            IActorRef fooActor = system.ActorOf(Props.Create(() => new FooActor()), "FooActor");

            fooActor.Tell("1");
            fooActor.Tell("2");

            Thread.Sleep(100);
            //system.Stop(fooActor);
            system.Shutdown();
            //fooActor.Tell(PoisonPill.Instance);

            system.AwaitTermination();
            Console.WriteLine("Shutdon Completed");
            Console.ReadLine();
        }

        Console.ReadLine();
    }
}
Hyungho Ko
@hhko
how to wait for all of actors are completed?
Suhas Chatekar
@schatekar
@Aaronontheweb I am still struggling to debug the multi node tests
Sometimes the tests run but no breakpoint is hit. other times visual studio just freezes
which version of visual studio do you use?
Hyungho Ko
@hhko
i am using visual studio 2015 and akka.net 1.0.4
i think shutdown method have to wait for all of actors completed.
is it bug?
Boban
@bobanco
@Horusiath , @Aaronontheweb is there any progress on the distributed-data? i would start porting it if none has started
jweimann
@jweimann
anyone know how to send to a clustered consistent-hashing-pool created on another port/process? Tried doing an actorselection & tell but it doesn't get there (deadlettered). tried creating the router on the secondary client but then it's a diff actor that receives the message. not sure if i'm trying to do something i shouldn't or just missing something simple
Ryan Davis
@rdavisau
@rogeralsing, looking good for local serialization tests. I gave it a run through a bunch of experiements in F# and didn't have any hitches. I did notice that I could not serialize a C# Action, though (whether or not you want to support that is another question)
If you share your akka branch I will try with some more complicated/remote experiments. I had noticed with some of the other serializers that what worked fine in-process would fail across processes/remotely
For Action, I saw the much-loathed VerificationException
Roger Johansson
@rogeralsing
I have a handful of tests that fail on my akka branch, null ref exception in the runtime code generated code .. going to take a while to debug that one :)
regarding delegates, I think those should just be ignored, it will result in really weird bugs if we start passing delegates across the wire... e.g.
Ryan Davis
@rdavisau
Haha, ok. I will try some basic IPC with sockets by hand then :+1:
Roger Johansson
@rogeralsing
@hhko, no that is not a bug, there is simply no way to observe if there are actors processing messages. lets say you have 1 mil actors, there is simply no way to synchronize that amount of work. when you think the last one is done, the first one might have started to process again.
Ryan Davis
@rdavisau
@rogeralsing also working well between processes :+1:
Roger Johansson
@rogeralsing
nice :)
James Andrew-Smith
@james-andrewsmith
Hello People - just wrapping my head around persistence - if I implement AtLeastOnceDeliveryActor, would I need to use a Stash as well? (I can't lose any messages and I can't assume the same host will be available).
Anthony Brown
@bruinbrown
@bobanco I've ported most of it, I'm just working on porting across the multinode tests at the minute
James Andrew-Smith
@james-andrewsmith
Is anyone working on a persistence library for ElasticSearch, ie: Akka.Persistence.ElasticSearch?
Roger Johansson
@rogeralsing
@james-andrewsmith I dont think there is tbh, havent heard of anyone
stevemesser
@stevemesser
Jason Roberts has posted another Pluralsight tutorial "Implementing Logging and Dependency Injection in Akka.NET"
Pablo Castilla
@pablocastilla
Could someone take a look at this?
Thanks so much! I am stucked :S
Cecil Phillip
@cecilphillip
There's another Akka .NET course on PluralSight .. http://www.pluralsight.com/courses/akka-dotnet-implementing-logging-dependency-injection. I haven't even gotten to watch the first one :smile: //cc @Aaronontheweb @rogeralsing
Roger Johansson
@rogeralsing
Its awesome, I watched it earlier
I learnt about Seq :) never heard of that log store before
Patrick Kelly
@featuresnap
Hi, n00b question. If I want to send a message to an actor that is physically on the same machine, but hosted in a different process, can I just use an ActorSelection referencing for instance akka://mysystem/user/Foo, or do i need to use a remote actor ref?
Roger Johansson
@rogeralsing
you can always use an actorselection, but it needs to have the correct protocol, e.g. "akka.tcp://mysystem@localhost:8080/user/Foo"
Ivan R. Perez
@irperez
Can anyone tell me how often the AtLeastOnceDeliveryActor retries failed messages?
@featuresnap @rogeralsing You are using Akka.Remote I'm assuming? In order to utilize "akka.tcp" you need the Akka.Remote nuget package.
Patrick Kelly
@featuresnap
@irperez @rogeralsing I did not set out to use Akka.Remote, or TCP, specifically. I wanted to do a little POC where I host an actor in a Windows service, and then have a console app (running on the same machine, but separate process) send a message into the actor system hosted on the server.
Jordan S. Jones
@jordansjones
@rogeralsing Seq is made by the same guy(s) that did Serilog
Roger Johansson
@rogeralsing
oh
James Andrew-Smith
@james-andrewsmith
I just wanted to say how awesome I am finding Akka.net! Every time I think up a possible "what about x" problem there seems to be a solution already available. The latest is persistence / IsRecovering, here I was thinking, but when I replay events then all this unwanted business logic is going to run (like emails sending etc). Nope :)
Ivan R. Perez
@irperez
And to think there is a ton more in the works! Looking forward to Akka.Cluster.Sharding!
Oleg Gavrilov
@OlegGavrilov
hi guys!
If I want to ask actor from a mvc app - I can do it only by creating new actorsystem and resolve actor from it?
Alexander Prooks
@aprooks
yes