Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 16:38
    Aaronontheweb commented #4022
  • 16:37
    Aaronontheweb commented #4022
  • 16:25
    IgorFedchenko synchronize #4022
  • 16:25
    IgorFedchenko synchronize #4032
  • 16:08
    IgorFedchenko commented #4022
  • 12:50
    IgorFedchenko commented #4032
  • 06:50
    dependabot-preview[bot] labeled #4033
  • 06:50

    dependabot-preview[bot] on nuget

    Bump Microsoft.NET.Test.Sdk fro… (compare)

  • 06:50
    dependabot-preview[bot] opened #4033
  • Nov 12 22:40
    Horusiath commented #4022
  • Nov 12 22:03

    dependabot-preview[bot] on nuget

    (compare)

  • Nov 12 22:03

    dependabot-preview[bot] on dev

    Bump Microsoft.SourceLink.GitHu… (compare)

  • Nov 12 22:03
    dependabot-preview[bot] closed #4028
  • Nov 12 20:30
    dependabot-preview[bot] synchronize #4029
  • Nov 12 20:30

    dependabot-preview[bot] on nuget

    Bump ApprovalTests from 3.0.10 … (compare)

  • Nov 12 20:30
    dependabot-preview[bot] edited #4029
  • Nov 12 20:30
    dependabot-preview[bot] synchronize #3991
  • Nov 12 20:30

    dependabot-preview[bot] on nuget

    Bump Microsoft.Extensions.Depen… (compare)

  • Nov 12 20:30
    dependabot-preview[bot] synchronize #4028
  • Nov 12 20:30
    dependabot-preview[bot] synchronize #4021
Hyungho Ko
@hhko
how to disconnect remote ActorSystem successfully. normally. remote ActorSystem print out error and warning messages stdout. I want to disconnect it without error and warning messages.
Hyungho Ko
@hhko
how to handle disconnection event from client AcorSystem in Server AcorSystem?
Bartosz Sypytkowski
@Horusiath
@Aaronontheweb @rogeralsing I think we should include one of the sql-based persistence plugins in core repo - it would be nice to actually being able to test Akka.Persistence.Sql.Common lib changes, and this is hard because we don't have any direct implementation in core repository
I guess sqlserver or sqlite would be good fit, since they have natural dependencies in .net environment or don't have any dependency at all
Hyungho Ko
@hhko
I can catch disconnected actor using Watch and Unwatch methods. but Watch and Unwatch methods only support disconnected actor. How to catch crashed another actorsystem?
Bartosz Sypytkowski
@Horusiath
@hhko you'll probably get disassociation error
from jvm akka: remote events
Hyungho Ko
@hhko
thank you for your consideration. I can understand it. Could I get example code associated it?
Roger Johansson
@rogeralsing
@Horusiath absolutely, that was one of the things I noticed in my auto code bug detector, there are types in akka.persistence that have 0 references in the core repo.. which feels odd
so having a reference implementation, e.g. sqlserver in the core would solve that
Hyungho Ko
@hhko
how to catch 'RemotingShutdownEvent' from another ActorSystem?
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?