Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Jan 17 14:08
    IgorFedchenko commented #4126
  • Jan 17 14:07
    IgorFedchenko synchronize #4126
  • Jan 17 01:36
    dependabot-preview[bot] synchronize #3985
  • Jan 17 01:36

    dependabot-preview[bot] on nuget

    Bump FsCheck.Xunit from 2.9.0 t… (compare)

  • Jan 17 01:36
    dependabot-preview[bot] edited #3985
  • Jan 17 01:36
    dependabot-preview[bot] synchronize #4066
  • Jan 17 01:36

    dependabot-preview[bot] on nuget

    Bump FSharp.Quotations.Evaluato… (compare)

  • Jan 17 01:36
    dependabot-preview[bot] synchronize #3986
  • Jan 17 01:36

    dependabot-preview[bot] on nuget

    Bump NUnit from 3.6.1 to 3.12.0… (compare)

  • Jan 17 01:36
    dependabot-preview[bot] edited #4066
  • Jan 17 01:36
    dependabot-preview[bot] edited #3986
  • Jan 17 01:35
    dependabot-preview[bot] edited #3986
  • Jan 17 01:35
    dependabot-preview[bot] edited #3985
  • Jan 17 01:35
    dependabot-preview[bot] edited #4066
  • Jan 17 01:34

    dependabot-preview[bot] on nuget

    (compare)

  • Jan 17 01:34

    dependabot-preview[bot] on dev

    Bump System.Configuration.Confi… (compare)

  • Jan 17 01:34
    dependabot-preview[bot] closed #4131
  • Jan 17 00:01
    dependabot-preview[bot] synchronize #4131
  • Jan 17 00:01
    dependabot-preview[bot] synchronize #4066
  • Jan 17 00:01

    dependabot-preview[bot] on nuget

    Bump System.Configuration.Confi… (compare)

Aaron Stannard
@Aaronontheweb
the commands behave like normal receives
you can behavior-switch those
Alex Achinfiev
@aachinfiev
Yes. I understand it better now :)
@Aaronontheweb Btw. Are there any plans to bring Akka.Persistence.Cassandra to work with latest 1.0.2 Akka.Persistence? I saw you update on one of the PRs but that was a while ago.
Aaron Stannard
@Aaronontheweb
yep, we're working on it
have an evil plan underway to get all of the Akka.Persistence implementations running with full integration testing again
which is what we've been waiting on
Alex Achinfiev
@aachinfiev
Is part of that update to change schema to support reverse lookup views by tags?
Aaron Stannard
@Aaronontheweb
yeah should be as part of Akka.Persistence.Query
which that PR supports
Alex Achinfiev
@aachinfiev
Cool
Aaron Stannard
@Aaronontheweb
the damn thing that's taken so long is getting our toolchain to play nice with Docker
spin up a Docker container for whatever database target we're testing against
allows for a bunch of fun stuff like being able to test against multiple versions of the same database simultaneously
Alex Achinfiev
@aachinfiev
Yeah, I have been building a docker stack for our various data stores (cassandra, elasticsearch, orientdb) to spin that up locally for testing. Works great with docker-compose, and then you can destroy the whole thing and start fresh quickly.
Aaron Stannard
@Aaronontheweb
I tried getting DataStax Enterprise to run inside Docker two weeks ago
failed miserably at that
too many issues with file system permissions inside the container
whereas it "just works" on a Ubuntu VM
I felt very un-hip :(
Alex Achinfiev
@aachinfiev
I currently didn't bother mounting the volumes because for local testing I don't want them to live for long. As long as I don't destroy container I can stop/start with the data. But if I do compose down then it starts fresh. Very handy.
Right now trying to figure out how to tweak our coordinator that manages persistent actors to kill them efficiently and without loosing messages. Current implementation keeps taking longer and longer during sustained load when I push thousands of messages through it. If I let coordinator kill the child immediately it keeps constant level of response time but looses in-flight messages.
Alex Achinfiev
@aachinfiev
@Aaronontheweb Have you guys tried to run Akka stack on Docker yet?
Bartosz Sypytkowski
@Horusiath
@aachinfiev Afaik @annymsMthd has a production system working on akka/mono/docker - he even published some docker scripts some time ago
Alex Achinfiev
@aachinfiev
@Horusiath Cool. Good to now. Thanks.
Eric Glanz
@ericgla
I'm new to Akka.Net, and am testing out scenarios where a child actor stops using the OneForOneStrategy I defined. Everything is working as expected, but I never seem to get a Terminated message on the parent when the child actor stops.
Looking at the Actor lifecycle diagram in the docs, I should be seeing a Terminated message at the parent. What am I missing here?
Eric Glanz
@ericgla
and just after posting I answered my own question.... child actors are not watched by default (which was my assumption), and need to be explicitly watched with Context.Watch(childActor)
Yin Zhang
@melcloud
Hi guys, do we have documents on how split brain problem is handled in akka.net? There is a good amounts of articles for akka, not sure if akka.net uses the same mechanism
Arjen Smits
@Danthar
yes it does
generally the jvm akka docs apply to akka.net as well
Bartosz Sypytkowski
@Horusiath
@melcloud I don't remember if custom downing provider are already present in the akka.net version available on nuget, or it's still laying down in dev branch
anyway by default no downing strategy is provided. You can change that to auto-down (which means that every node will automatically mark as downed other nodes it couldn't reach within specified timeout) - but this may lead to split brain situation.
On the akka jvm you have at least 4 more downing providers, but they are part of reactive subscription and are part of Lightbend's proprietary stack
Yin Zhang
@melcloud
@Horusiath ah, got it. Yes, those 4 downing providers are what I am looking for. This means in akka.net, we need to keep monitoring status to manually downing actor?
Matthew Little
@zone117x
Hey guys curious of akka.net is good for my use case. I have an asp.net core server brokering messages between clients on net451 using websockets and msgpack serialization
the net451 client apps are 1) data collector, and 2) remote controller for the data collector and data viewer
Yin Zhang
@melcloud
@zone117x so what would you like to use akka.net for ?
Matthew Little
@zone117x
I'm having to write a lot of code to manage the websocket connection and especially message routing
Yin Zhang
@melcloud
I see. Does the .ne tcore server doing any thing special?
Matthew Little
@zone117x
its using asp.net core mvc for the web interface and some REST apis, and routing for the websocket connections
Yin Zhang
@melcloud
So you want to replace routing part of the websocket connections?
The akka.net is not available on net core yet. (correct me if I am wrong)
But for you situation, can you just use a load balacer / proxy to route traffic instead of relying on code?
Matthew Little
@zone117x
I'd like to use it for message routing over the websocket connections
Alex Achinfiev
@aachinfiev

I have a PersistentReceiveActor that sends itself a PoisonPill after 5 seconds of inactivity. I see a scenario where I see WriteMessagesSuccessful & WriteMessageSuccess are going to deadletter from akka.persistence.journal.inmem that were directed to the given actor. Does missing those messages mean that Persist callback won't wire or these are used for other confirmation?

        Command<CreateSecurity>(c =>
        {
            Persist(new SecurityCreated() { Id = c.Id, Name = c.Name }, e =>
            {
                Context.System.EventStream.Publish(e);
                Create(e);
                BecomeInitialized();
            });
        });
       Command<ReceiveTimeout>(t => Self.Tell(PoisonPill.Instance));
....
    protected override void PreStart()
    {
        base.PreStart();
        Context.SetReceiveTimeout(TimeSpan.FromSeconds(5));
    }

Or those are just confirmation and actor correctly persisted the data? Thanks.

Yin Zhang
@melcloud
@zone117x I assume u route message based on some message property, lets say postcode. You can definitely have actor which listen for incoming requests, look up postcode, spin up a child and begin a web socket connection there. But akka.net currently has no support for .net core, which means somehow you need to proxy it to a net451 app.
Yin Zhang
@melcloud
@aachinfiev yes, it is used by AsyncWriteJournal.cs to send reply to requestor upon sucessfully write
@aachinfiev is there any reason you want to self destruct a persist actor?
Justin Oehlmann
@GREETASolutions_twitter
quick poll ..akka.noob Reactive Messaging patterns or Functional and Reactive Domain Modeling