Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Dec 05 17:21
    Aaronontheweb synchronize #4079
  • Dec 05 17:20
    Aaronontheweb labeled #4084
  • Dec 05 17:20
    Aaronontheweb labeled #4084
  • Dec 05 17:20
    Aaronontheweb milestoned #4084
  • Dec 05 17:20

    Aaronontheweb on dev

    Remove string interpolation fro… (compare)

  • Dec 05 17:20
    Aaronontheweb closed #4084
  • Dec 05 17:20
    Aaronontheweb commented #4084
  • Dec 05 15:43
    ismaelhamed opened #4084
  • Dec 04 23:34

    Aaronontheweb on dev

    Made cleanup call thread-safe (… (compare)

  • Dec 04 23:34
    Aaronontheweb closed #4081
  • Dec 04 23:34
    Aaronontheweb closed #4020
  • Dec 04 19:08
    Aaronontheweb commented #4079
  • Dec 04 18:35
    maratoss review_requested #4079
  • Dec 04 18:26
    maratoss synchronize #4079
  • Dec 04 07:42
    jiyeongj edited #4083
  • Dec 04 06:45
    jiyeongj opened #4083
  • Dec 04 06:35
    dependabot-preview[bot] labeled #130
  • Dec 04 06:35
    dependabot-preview[bot] opened #130
  • Dec 04 06:35

    dependabot-preview[bot] on nuget

    Bump System.Data.SqlClient from… (compare)

  • Dec 03 19:10
    Aaronontheweb synchronize #4081
Aaron Stannard
@Aaronontheweb
@rogeralsing hehe - nice.
Emil Ingerslev
@emilingerslev
@Aaronontheweb I hoped that was true. I makes the setup very reliable, which is good. Thanks :)
jweimann
@jweimann
@Aaronontheweb @Coinio I don't think the broadcast router makes sense for those balls, unless they're all supposed to change velocity at the same exact second to the same value, but I doubt that's the expected case
Bartosz Sypytkowski
@Horusiath
with akka-jvm 2.4, there are a lot of changes in cluster sharding:
  1. They moved persistence backed for sharding coordinator from Akka.Persistence to CRDTs
  2. Protobufed messages
  3. Graceful shutdown
Aaron Stannard
@Aaronontheweb
quite the moving target
but I get it - that stuff's not trivial to implement
Birnsen
@Birnsen

Hey everyone. Fantastic project! Following a while now... Watched your cluster contrib meeting on YT and there you mentioned the need of a MultiNode Visulaizer.
So I did a little something :). It is not pretty and it is written in F# (currently learning so code is probably a mess), so do not expect too much.
But maybe I can do something out of it (spit out static HTML) if needed.

https://github.com/Birnsen/MultiNodeVisualizer/blob/master/mnv.png

The numbers are the amount of events at that given moment. If an test fails is also not implemented yet but should be easy to do...
Had only one file to test it so others will probably fail.

derrickcrowne
@derrickcrowne
Are there any docs or examples on how to use UdpConnected in Akka.IO? There are extension methods on ActorSystem for Udp() and Tcp() but I couldn't find one for UdpConnected().
derrickcrowne
@derrickcrowne
I tried sending the UdpConnected.Connect message to ActorSystem.Udp() but it said it only responds to Bind and SimpleSender
Joshua Benjamin
@annymsMthd
@Aaronontheweb @derrickcrowne is starting to use Akka.IO to build a vehicle simulator
Suhas Chatekar
@schatekar
@Birnsen is that something you are outputting on the console?
Birnsen
@Birnsen
@schatekar yes
but the json file as input not real time
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