Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Jan 27 22:16
    dependabot-preview[bot] synchronize #3985
  • Jan 27 22:16

    dependabot-preview[bot] on nuget

    Bump FsCheck.Xunit from 2.9.0 t… (compare)

  • Jan 27 22:16
    dependabot-preview[bot] edited #3985
  • Jan 27 22:15
    dependabot-preview[bot] edited #3985
  • Jan 27 22:15
    dependabot-preview[bot] synchronize #3986
  • Jan 27 22:15

    dependabot-preview[bot] on nuget

    Bump NUnit from 3.6.1 to 3.12.0… (compare)

  • Jan 27 22:15
    dependabot-preview[bot] synchronize #3985
  • Jan 27 22:15

    dependabot-preview[bot] on nuget

    Bump FsCheck.Xunit from 2.9.0 t… (compare)

  • Jan 27 22:15
    dependabot-preview[bot] edited #3986
  • Jan 27 22:15
    dependabot-preview[bot] edited #3985
  • Jan 27 22:15
    dependabot-preview[bot] synchronize #4066
  • Jan 27 22:15

    dependabot-preview[bot] on nuget

    Bump FSharp.Quotations.Evaluato… (compare)

  • Jan 27 22:15
    dependabot-preview[bot] edited #4066
  • Jan 27 22:15
    dependabot-preview[bot] edited #4149
  • Jan 27 22:14
    Aaronontheweb synchronize #4128
  • Jan 27 22:14

    Aaronontheweb on nuget

    (compare)

  • Jan 27 22:14

    Aaronontheweb on dev

    Bump Hyperion from 0.9.11 to 0.… (compare)

  • Jan 27 22:14
    Aaronontheweb closed #4149
  • Jan 27 22:13
    dependabot-preview[bot] edited #3986
  • Jan 27 22:13
    dependabot-preview[bot] edited #3985
Hyungho Ko
@hhko
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();
    }
}
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
Oleg Gavrilov
@OlegGavrilov
thanks @aprooks
Alexander Prooks
@aprooks
np:)
just make sure you don't create actor system per each request to an actor.
Pablo Castilla
@pablocastilla
or to do it through a cluster :$ , for me Ask doesn't work :( I can not get the response through the cluster
James Andrew-Smith
@james-andrewsmith

I was wondering if someone could help me with clustering. As I've clearly missed something.

I'm playing with the samples (Cluster Transformation), and I'm trying to work out how to ensure there is on a single version of an actor with the same ID in the cluster.

In the sample, the LaunchBackend function is creating an actor with the path "backend". My initial understanding was that the paths would be unique over the cluster?

What's the pattern / example for ensuring an actors path is unique within the cluster? Is this a configuration change? Do I need to use cluster routers? (I've been trying this but there doesn't appear to be any change in behavior).

All help is much appreciated.

Pablo Castilla
@pablocastilla
james-andrewsmith you need a consistent-hash-group router
well, that's if you need a router. On the other hand I think you can create the actor in your nodes and access them directly through the IP in the name.