Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 06:31
    Aaronontheweb commented #4085
  • 06:28
    Aaronontheweb commented #4085
  • 06:24
    Aaronontheweb commented #4085
  • Dec 07 11:49
    IgorFedchenko commented #4085
  • Dec 07 10:31
    IgorFedchenko commented #4085
  • Dec 07 08:36
    IgorFedchenko commented #4085
  • Dec 06 20:57
    IgorFedchenko commented #4085
  • Dec 06 20:32
    IgorFedchenko commented #4085
  • Dec 06 20:01
    IgorFedchenko commented #4085
  • Dec 06 19:55
    IgorFedchenko commented #4085
  • Dec 06 16:22
    Aaronontheweb labeled #3997
  • Dec 06 16:22
    Aaronontheweb closed #3997
  • Dec 06 16:20
    IgorFedchenko commented #3997
  • Dec 06 16:08
    IgorFedchenko commented #4085
  • Dec 06 15:50
    Aaronontheweb assigned #4085
  • Dec 06 15:50
    Aaronontheweb labeled #4085
  • Dec 06 15:50
    Aaronontheweb labeled #4085
  • Dec 06 15:49
    Aaronontheweb closed #4032
  • Dec 06 14:58
    IgorFedchenko commented #4032
  • Dec 06 14:57
    IgorFedchenko opened #4085
Suhas Chatekar
@schatekar
How difficult would it be to make your program spit out an html that would render the same thing?
Birnsen
@Birnsen
not that much... all the data should be given. only have to do a the skeleton to put the data in.
i am not that much of a js guy though
Patrick Mohr
@kc7zzv
Does Akka have an equivalent to RxEx's .Buffer()? Buffer works by queuing up messages, but instead of sending them through as they arrive, it will queue up to n messages, or queue up messages for n seconds. When either the time or the capacity limit is reached, it sends through all the messages at once. For example, I might put "buffer 5 seconds" in front of writing changes to the cache to disk. That way I can merge the changes into a bigger write. (Sacrificing up to 5 seconds of data if the program crashes.)
I could probably build this using an Actor, and a delayed message send using the scheduler, but I'm guessing something like this already exists, if I just knew the name.
Chris Martin
@trbngr
@Aaronontheweb playing with Akka.Persistence.Cassandra but can't get tests to run. NullRef serializing a Persistent with an int payload
everything is up to date
Aaron Stannard
@Aaronontheweb
@trbngr yeah, we have a bug logged here akkadotnet/akka.net#1235
not 100% sure what's going on there - haven't investigated yet, but it looks like the Cassandra plugin was depending on something for serialization that the other plugins werent
Chris Martin
@trbngr
well balls
it's weird man. I can pull the serialization code into the Cassandra project and it serializes just fine
Chris Martin
@trbngr
PR sent
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 :)