Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 13:36
    Aaronontheweb commented #3973
  • 13:34
    dependabot-preview[bot] synchronize #3995
  • 13:34

    dependabot-preview[bot] on nuget

    Bump BenchmarkDotNet from 0.10.… (compare)

  • 13:34
    dependabot-preview[bot] edited #3995
  • 13:34
    dependabot-preview[bot] synchronize #3993
  • 13:34

    dependabot-preview[bot] on nuget

    Bump Google.Protobuf from 3.9.1… (compare)

  • 13:34
    dependabot-preview[bot] synchronize #3991
  • 13:34

    dependabot-preview[bot] on nuget

    Bump Microsoft.Extensions.Depen… (compare)

  • 13:34
    dependabot-preview[bot] synchronize #3989
  • 13:34

    dependabot-preview[bot] on nuget

    Bump ApiApprover from 3.0.1 to … (compare)

  • 13:34
    dependabot-preview[bot] synchronize #3992
  • 13:34
    dependabot-preview[bot] edited #3993
  • 13:34
    dependabot-preview[bot] synchronize #3985
  • 13:34

    dependabot-preview[bot] on nuget

    Bump System.Reflection.Emit fro… (compare)

  • 13:34
    dependabot-preview[bot] synchronize #3986
  • 13:34

    dependabot-preview[bot] on nuget

    Bump FsCheck.Xunit from 2.9.0 t… (compare)

  • 13:34
    dependabot-preview[bot] synchronize #3983
  • 13:34

    dependabot-preview[bot] on nuget

    Bump NUnit from 3.6.1 to 3.12.0… (compare)

  • 13:34
    dependabot-preview[bot] edited #3991
  • 13:34

    dependabot-preview[bot] on nuget

    Bump ApprovalUtilities from 3.0… (compare)

Bartosz Sypytkowski
@Horusiath
this would help a lot
Andrey Leskov
@andreyleskov
right now no 8 ( working on it. I know it is correlated with system restart )
when I restart applications messages start to reach their subscribers for Ids not working before
Bartosz Sypytkowski
@Horusiath
routee actors are standard ones or maybe persistent actors or something else?
Andrey Leskov
@andreyleskov
in general any types of actors
but not persistent for sure
problems arise with routee witch itself controls a pack of persistence actors
and reroutes messages to it
routee just does not receive a message
Bartosz Sypytkowski
@Horusiath
routee witch itself controls a pack of persistence actors or router witch itself controls a pack of persistence actors?
Andrey Leskov
@andreyleskov
routee. I've tried a pool with persistence actors, it was bad )
Bartosz Sypytkowski
@Horusiath
I wanted to say the same ;)
Andrey Leskov
@andreyleskov
This message was deleted
schema is : publish message to event stream -> controller with pool router -> persistence actor living in controller internal collection
Bartosz Sypytkowski
@Horusiath
it would be good to make sure on which connection message has been lost
Andrey Leskov
@andreyleskov
I suspect hashing logic, and even added logging inside )) But cannot make logging work for now, investigating
Bartosz Sypytkowski
@Horusiath
heh, I've never liked routers (especially CH), too much magic. Never used them in any practical scenario and I'm still happy, that they're not going to be a part of akka-typed
Andrey Leskov
@andreyleskov
I'll try to remove ConsistentHashingPool at all as an option
BTW: i have a stream of events published to EventStream, and stateless handlers writing events into DB
How would you recommend to parallel handlers work? I'm using random pool for now
Bartosz Sypytkowski
@Horusiath
this week I was working on new sql journal impl, which was optimized to handle much greater amount of requests than previous one using request batching (see: #2389)
Andrey Leskov
@andreyleskov
@Horusiath cool ! Can't wait for it
and is their any plans to remove startup query for all ids in database ?
select distinct PersistenceId from Journal
Bartosz Sypytkowski
@Horusiath
but this is quite big amount of code. For simpler case you can simply use random pools. I don't even know if EventStream is really what you need. I'm used to just passing actor reference to destination actor in constructor or in message itself.
@andreyleskov yes, I've removed it. Now it will be only called once, when someone actually will request for all persistence ids
Andrey Leskov
@andreyleskov
yesss! thank you a lot ^_^
Bartosz Sypytkowski
@Horusiath
I thank you ;) Your feedback was really welcome here.
Andrey Leskov
@andreyleskov
after several months in production I have 1.5 millions ids, so query is killing my db on start
Andrey Leskov
@andreyleskov
btw : after investigation it seems if I subscribe an actor with consistent hashing pool to EventStream only one of several spawned pool children will receive messages
will create a reproducable test
Andrey Leskov
@andreyleskov
no, it is wrong hypothesis
Andrey Leskov
@andreyleskov
It seems it is my fault - receivers just die with time >_<
Andrey Leskov
@andreyleskov
@Horusiath Thanks a lot for help, I've shooted myself : " If a third party terminates a child by way of the system.Stop(child) method or sending a PoisonPill, the supervisor might well be affected."
controller terminates children after inactivity : they call Context.Stop(self)
and controller watches over them to get Terminated message
and dies after first clean
Maxim Cherednik
@maxcherednik
hi guys, got a short q. Do I need to cache my request messages?
so that to avoid gc pressure
Aaron Stannard
@Aaronontheweb
@maxcherednik cache it for what?
Aaron Stannard
@Aaronontheweb
(just so I better understand the context)
Maxim Cherednik
@maxcherednik
@Aaronontheweb for instance I am doing 10 mln requests to some other actors, someActor.Tell(new Request())
Maxim Cherednik
@maxcherednik
I know I should just measure it. I just observed lots of gc in visual studio metrics. I was just wondering about general approach in akka. But since I didn't find anything on google, this problem does not exist. Or even better, 10 mln requests? probably I should just reconsider my implementation...
Maxim Cherednik
@maxcherednik
Screen Shot 2016-12-04 at 10.30.05.png
Michael Pavlovsky
@michaelp
Hi. I am looking for akka-testkit analog for akka.net ; In general, What is advised way of unit test a single actor? I am looking for a snippet similar to the following scala code
val actorRef = TestActorRef(new MyActor)
Aaron Stannard
@Aaronontheweb
@michaelp we have the Akka.TestKit
any core devs who can review akkadotnet/akka.net#2398 ?
Michael Pavlovsky
@michaelp
@Aaronontheweb thanks, i found it. I wish it were part of the documentation page.
Aaron Stannard
@Aaronontheweb
yeah, we need to add some to the site still