@stijnherreman Please read this article: https://github.com/petabridge/akkadotnet-code-samples/tree/master/PipeTo
@stijnherreman closure = Sender
@stijnherreman These articles have helped to be grounded in the Ask/PipeTo pattern
So you receive a request for your REST data. You detect that you dont have it in cache
where you wait for your response message
and stash everything else
once you receive your response message
unstash all. And serve all the other stuff from your cache
that way you dont have to block your actor's execution. And you are sure you only pay the hit once
From your REST API Controller, ask is the only way to do request -> response style communication with an actor. So yes. Then you should use Ask
But then your communicating from outside your actor system. So you don't have much options there :)
Here's the link: AkkaNetContrib/Akka.Persistence.MongoDB#30
I'm having trouble to inject a specific HOCON config for my cluster-sharding section into my persistence plugin. When I look at other implementations of persistence plugins, I see two flavors: a constructor with and without a config parameter. Eg. SqliteJournal (https://github.com/akkadotnet/akka.net/blob/1595e1e832fb42b4a70a4ebf0b3dc52b87b40a96/src/contrib/persistence/Akka.Persistence.Sqlite/Journal/SqliteJournal.cs) has public SqliteJournal(Config journalConfig), whereas other persistence plugins do not provide the Config parameter. What's the deal with the Config parameter? Will the cluster sharding plugin inject the current config into the persistence plugin via that ctor?
it uses a
journal-plugin-id and snapshot-plugin-id setting which contains the absolute path to the journal or snapshot plugin config entity
if you dont define that it uses the system default (whatever you have defined)
So in short cluster sharding does not initialise the persistence plugin. Its reponsible for doing that itself. In short through its respective hocon config or manually before you intialise the cluster sharding system
If you dont define anything it will fallback to whatever is in the hocon config
And its also used for testing :P
@jackowild we probably already seen your PR come up. but I forwarded your request internally as well. Can't make any promises as to when someone will get around to it though.
@Danthar but how does the cluster sharding plugin tell the persistence plugin which config to use? I mean, if I look at the persistence plugins they all know how to persist to a journal using the default journal config (eg. akka.persistence.journal.sql-server). They do not check the config for the cluster setting, so how does the cluster sharding persistence config (as configured via the journal-plugin-id, as you said) flow to the persistence plugin?
For example, this plugin (https://github.com/alexvaluyskiy/Akka.Persistence.Azure/blob/dev/src/Akka.Persistence.AzureTable/AzureTablePersistence.cs#L85) always uses the same config section 'akka.persistence.journal.azure-table' for its persistence. It seems not able to get a different config for eg cluster sharding. This means both normal actor state and cluster sharding state will end up in the same table (as configured by that one config section)
with the sql-server persistence plugin it seems to work when I configure it like this (https://github.com/promontis/stylister.sample/blob/master/Liking/Stylister.Liking.Downloader/settings.hocon), but I don't get how the akka.persistence.journal.sharding config section is passed to the sql-server persistence plugin
Hey guys, question: whenever using a supervising actor for persistent actor (in case where they cannot really be
created or recreated on demand), is the approach of creating actors while replaying event mentioned in "akka in action"
book (https://github.com/RayRoestenburg/akka-in-action/blob/master/chapter-persistence/src/main/scala/aia/persistence/ShoppersSingleton.scala#L71)
the best way to go? Or some streaming from some other source would be more applicable?
created or recreated on demand), is the approach of creating actors while replaying event mentioned in "akka in action"
book (https://github.com/RayRoestenburg/akka-in-action/blob/master/chapter-persistence/src/main/scala/aia/persistence/ShoppersSingleton.scala#L71)
the best way to go? Or some streaming from some other source would be more applicable?
hey guys. I have this scenario where I need to able to do things like determining for a given user: nearby shops, distance from a shop, distance and time away from delivery person/courier.
For this I decided to create a "Locations Service" and the idea is to have other services actors make requests to it to get location related data using Akka.Remote .
For example: Shop Service asks locationsService which are the nearby shops for a given point/user location (latitude, longitude). My problem is that currently I have the dbs separated by each service. How would shop service know which shops to present to the user? Right now all I have is geo spatial data stored in locations service db and a name for each entry. I feel like I'm missing something and I might be even confusing myself :/
@defrag2_twitter As long as it's idempotent and won't fail (in your example it's get-or-create an actor), it should be good to go
however, I could have a persistent actor registering "login" events for each shop, so this way I could tell which shops are available to order from
i have a question... i can'T seem to get akka testing to run wiht nunit 3 (any version). i seen there were some fixes done around an issue regarding nunit3... but i can't seem to make it work. anyone got any clues?
Hey guys, I'm scaling my application with cluster sharding, and have a look at multinode test kit (http://getakka.net/articles/networking/multi-node-test-kit.html). How it supposed to be debugged? is there any guide? may be runners for Resharper Tests, as for NBench ? (https://github.com/Pro-Coded/Pro.NBench.xUnit) I can imaging only attach VS to multinode test runner, and it seems to be painful and long process. (
@andreyleskov debugging MNTR specs is a dark art