Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Apr 06 22:45

    Aaronontheweb on dev

    sharding - release shard lease … (compare)

  • Apr 06 22:45
    Aaronontheweb closed #4369
  • Apr 06 22:45
    Aaronontheweb milestoned #4369
  • Apr 06 22:45
    Aaronontheweb labeled #4369
  • Apr 06 22:45
    Aaronontheweb commented #4363
  • Apr 06 22:31
    yesh-nadella commented #4363
  • Apr 06 22:05
    Arkatufus commented #4368
  • Apr 06 19:55
    zbynek001 opened #4369
  • Apr 06 17:38
    Aaronontheweb assigned #4368
  • Apr 06 17:38
    Aaronontheweb labeled #4368
  • Apr 06 17:37
    Aaronontheweb milestoned #4368
  • Apr 06 17:37
    Aaronontheweb labeled #4368
  • Apr 06 15:07
    PiotrJustyna opened #4368
  • Apr 03 22:24
    huzaifak opened #4367
  • Apr 03 21:45
    Aaronontheweb commented #4344
  • Apr 03 05:55
    Lutando commented #4344
  • Apr 02 17:23
    huzaifak commented #4303
  • Apr 02 17:23
    huzaifak closed #4303
  • Apr 02 02:13
    ShawnYun commented #4366
  • Apr 01 17:18
    huzaifak commented #4303
Aaron Stannard
@Aaronontheweb
I'm rolling out a management tool for Akka.NET networks soon and this issue gave me a good idea for some Akka.Remote profiling instrumentation
Sean Gilliam
@sean-gilliam
Bartosz Sypytkowski
@Horusiath
@Silv3rcircl3 I think that even without working tests akkadotnet/Alpakka#6 is ready to merge. Also I think, I'm missing permissions to Alpakka repository
Marc Piechura
@marcpiechura
Done
Bartosz Sypytkowski
@Horusiath
Thanks, I think I've forgot README file with API description there :P
Marc Piechura
@marcpiechura
Examples are enough ;-)
Edward Adjei
@eddadjei
is there a way to query an actors mail box for a specific message type?
Nicolas Bourbaki
@b0urb4k1
Is there anything that allows me to deal with limited resources in akka.net? Eg i would like to build something like a queue of items that one agent manages and that agent dispatches jobs to ogher agents.
But i want to limt on how many of these jobs can run, with the number of agents that are connected.
Edward Adjei
@eddadjei
@Aaronontheweb can I use ConsistentHashing to prevent messages from going to multiple actors in a pool router if i dont want to allow multiple actors runnning the same job type?
Sean Farrow
@SeanFarrow
@all I've got an actor that currently uses switchable behaviors, but there's now like 8 of them, is it worth converting this to an fsm? Are there any fsm examples?
DaveArkley
@DaveArkley
Is Akka.Net supported on Android/ios platforms?
Alex Valuyskiy
@alexvaluyskiy
No
We will add NetStandard1.6 support in 1.5, it will be possible to run it on Xamarin
DaveArkley
@DaveArkley
and because u use NetStandard also Windows Linux and OSX?
Alex Valuyskiy
@alexvaluyskiy
yes
DaveArkley
@DaveArkley
Thanks Alex. Do you have a timeline for 1.5 release?
ollivogel
@ollivogel
Hi. Can anybody please tell me how I can get rid of the repeating "Akka.Cluster.GossipStatus" log message when I start the actorsystem?
Bartosz Sypytkowski
@Horusiath
@alexvaluyskiy @DaveArkley I think it may run through Mono
@b0urb4k1 this sounds like a standard router pattern
ollivogel
@ollivogel
Behause this Repeating message is annoying and useless for my log file and I don't know how to shut it off.
Sean Gilliam
@sean-gilliam
@ollivogel have you tried? this should mute info logging of cluster events
akka {
  cluster {
    log-info = off
  }
}
ollivogel
@ollivogel
@sean-gilliam already tried this guy. However, without success.
ollivogel
@ollivogel
@sean-gilliam retried this setting. Seems to work. Maybe I did something wrong the first time. Thx.
Damian Reeves
@DamianReeves
@Aaronontheweb Any plans to update WebCrawler docs to have a explanation of what's now going on with the change to Streams... things are different than what is described in the ReadMe
Keith Nicholas
@keithn
Whats the best way to have an actor that periodically polls a resource until something interesting happens?
would I do it by ... Poll -> Sleep -> Self Message to Poll again
Bartosz Sypytkowski
@Horusiath
@keithn maybe not sleep, but simple Context.System.Scheduler.ScheduleTellRepeatedlyCancellable(initialDelay, interval, Self, Message, Self) should do the job
Keith Nicholas
@keithn
nice
Weston
@ronnyek
so akka streams
would they be good for having connections sending a bunch of raw data as fast as they can
and secondly
do I have to have something running full framework connecting to streams?
or could I have a socket from other origins conenct to an endpoint that feeds a gob of data into akka.net streams
(thinking devices that dont run .net)
Weston
@ronnyek
are there any examples that I can compile and run for akka.io
I saw documentation that showed how to utilize it to some degree
but its def not compilable code
Weston
@ronnyek
apologies
brain fart on my part
Weston
@ronnyek
anyone alive?
I've got more questions regarding .io and streams
Arjen Smits
@Danthar
Akka streams can certainly be used in combination with akka.io. But afaik there is no OOB sink/source for akka.io atm
@ronnyek should be do-able though
Jay DeBoer
@jaydeboer
Does anyone happen to know of any good examples for unit testing snapshot recovery in an actor? I am trying to write some tests around a persistent actor and the actor will restart, but it seems like recover is never being called. I've also tried putting breakpoints in the SaveSnapshotSuccess and SaveSnapshotFailure message handlers and they are never called during the test. PreRestart and PostRestart are being called in the actor under test, the pieces of state that are set in the constuctor are setup properly after restart, but no snapshot info seems to make it through. Do I need to initialize the actor with some HOCON to be able to save snapshots?
Arjen Smits
@Danthar
Never unit tested snapshot recovery in a custom actor. And even then. I'd test the end result and not the mechanism itself. Persistence itself has pretty extensive unit tests in the akka core repo.
but other then that
if you want to run persistence inside a unit test, normal configuration stuff applies
so you will need to load persistence configuration through hocon
otherwise defaults will apply, which is in-memory for eventsourced storage, and i think for snapshots as well, but im not sure