Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 14:40
    cptjazz synchronize #3974
  • 14:07
    cptjazz opened #3974
  • 08:30
    ismaelhamed commented #3937
  • Oct 12 15:50
    IrvinDominin opened #127
  • Oct 11 18:21
    Aaronontheweb commented #3973
  • Oct 11 18:20
    Aaronontheweb commented #3937
  • Oct 11 18:16
    Zetanova commented #3937
  • Oct 11 18:11
    Zetanova commented #3937
  • Oct 11 15:09
    Aaronontheweb commented #3937
  • Oct 11 15:08
    Aaronontheweb commented #3937
  • Oct 11 14:36
    Aaronontheweb commented #3973
  • Oct 11 01:00
    Horusiath commented #3057
  • Oct 10 20:02
    IgorFedchenko synchronize #3973
  • Oct 10 19:59
    IgorFedchenko synchronize #3973
  • Oct 10 19:58
    IgorFedchenko commented #3973
  • Oct 10 19:53
    IgorFedchenko opened #3973
  • Oct 10 14:04
    stijnherreman commented #3057
  • Oct 10 13:54
    Aaronontheweb commented #3970
  • Oct 10 13:54
    Aaronontheweb synchronize #3970
  • Oct 10 10:10
    Zetanova commented #3937
Michael Tissen
@rubiktubik
Hello, i'am using Akka.Persistence for a event-sourced application and i was wondering if one of the Akka.Persistence Plugins Support Persistence.Query?
Lev Lehn
@llehn

Regarding DI (autofac) integration. The docs say: The basic functionality is provided by a DependencyResolver class, that can create Props using the DI container. with example ending with this IDependencyResolver resolver = new XyzDependencyResolver(someContainer, system);

then there's When creating actorRefs straight off your ActorSystem instance, you can use the DI() Extension..

I don't understand that - in the example the resolver isn't used anywhere. And where does the system.DI() method know which DI container to use?

mwardm
@mwardm
5th
Chris Ochs
@gamemachine
so a comment on the akka documention style. I see this pattern a lot. Some part of the doc will go into all sorts of detail on stuff most people don't need to know, but then fail to document the basics, the stuff you have to know. http://getakka.net/docs/working-with-actors/identifying-actors-via-actor-selection is a good example. It never actually say's where you get the actor identity from. Sender? ActorIdentity .Subject?
Weston
@ronnyek
so if I want to build a console app, and have it connect or share an actorsystem with a webapp
is that clustering and requiring lighthouse?
Chris Ochs
@gamemachine
if both have static ip's and can reach each other, I don't see a reason for lighthouse really. just put the addresses of both as the seed nodes in both apps
or same address different ports that works also
Arjen Smits
@Danthar
@ronnyek at the very least that you would need akka.remote. You can create an server/client or peer to peer connection with akka.remote manually
akka.clustering layers on top of akka.remote and adds service discoverability and reliability things that would expect from a full blown cluster
Weston
@ronnyek
Ok...
I think I'll do that and add clustering later... Need to simplify this project for experimentation
Remove variables until I am familiar with and comfortable with Akka.net
Tomasz Jaskula
@tjaskula
Is this the only way defining parent/child relationship with FSharp API ? cc: @Horusiath
let playback = 
        spawn system "Playback"
        <| fun parentMailbox ->
            let child = 
                spawn parentMailbox "child" 
                    <| fun childMailbox ->
                        childMailbox.Defer (fun () -> printfn "Child stopping")
                        printfn "Child started"
                        let rec childLoop() = actor {
                            let! msg = childMailbox.Receive()
                            return! childLoop()
                        }
                        childLoop()
            cprintfn ConsoleColor.Gray "Creating parent actor..."
            // define parent behavior
            let rec loop() = actor {
                let! msg = parentMailbox.Receive()
                child.Forward(msg)  // forward all messages through
                return! loop ()
            }
            loop ()
Bartosz Sypytkowski
@Horusiath
@tjaskula using Akka.FSharp? Yes. But in normal conditions you'd probably move child behavior to separate function
Arsene T. Gandote
@Tochemey
@ronnyek you can build a full blown reactive Web applications using Akka without clustering and Akka remote. It is sth I have done.
Weston
@ronnyek
Basically shooting for say a web application and another worker service
Seems like good have remote or something for that
You'd need
Arsene T. Gandote
@Tochemey
OK
Weston
@ronnyek
You'd know more than I would... I am just saying from my minimal experience... That seems like that would be the case
Arsene T. Gandote
@Tochemey
Never mind
Carey Free
@Cawifre
@llehn In the case of Autofac, you pass the container and the actor system into the constructor for AutoFacDependencyResolver and the wiring is automagic under the hood. You can see an example on the Akka.DI.AutoFac readme. (Incidentally, what is with the inconsistent capitalization all over that repo? Should always be "Autofac", not "AutoFac".) If this world is even a little kind, then the plug-ins for other containers work the same way.
Weston
@ronnyek
any hope of .net core support, or are is it more likely that support will come with netstandard2? I know there were a few diff issues in github, but seems like all were kinda outstanding
adityasharmacs
@adityasharmacs

Hi All, I am trying out Journaling using Mongo Db, just wanted to know if apart frmo the github repo "https://github.com/akkadotnet/Akka.Persistence.MongoDB" is there any place where I can get code that explains Database storage in Journaling for MongoDb ? I have also read the following pages:

  1. https://petabridge.com/blog/intro-to-persistent-actors/
  2. http://bartoszsypytkowski.com/how-akka-net-persistence-works/

But didn't come across a pseudo code that shows entries being saved into Database using Journaling in MongoDb.

Any help is highly appreciated.

Bartosz Sypytkowski
@Horusiath
@adityasharmacs I guess, that the test suite for this plugin would be a first place to go. Also AFAIK MongoDB plugin requires setting bson schema attributes for each type - which instances will you persist - manually at actor system startup
adityasharmacs
@adityasharmacs
Hi @Horusiath : I am newbie to this, can you please give me some more pointers on this? Or any more references where I should look it up?
Bartosz Sypytkowski
@Horusiath
@adityasharmacs I'm not sure, where you could possibly find more references. Maybe @Silv3rcircl3 could help
fanoI
@fanoI
Good Afternoon! I've two questions regarding Akka.Net / Actors:
  1. It is possible to start an application as command line and then create an Actor than span a GUI (Winform, WPF or GTK#), there is an example of communication with Winform but another Actor is created in the UI thread, I'd like to make the GUI an Actor itself
  2. What about databases? Can I make an Actor that deals with the DB using Entity Framework?
Marc Piechura
@marcpiechura
@adityasharmacs you need to register your event types and snapshot types in the BsonClassMap before you can use them. Regarding examples, any available for persistence should work, you only need to change the hocon config and add the types to the class map
Michael Chandler
@optiks
@Aaronontheweb, commit 69709352
....changes the CreateTestProbe() behaviour to create the test actor under system, instead of user. Is this a deliberate change?
This breaks some of tests which rely on ActorSelection.
TestKitBase.cs:449 FYI
Daniel Söderberg
@raskolnikoov
@Danthar @Horusiath @Aaronontheweb what's the difference between Akka.Testkit.Xunit/Xunit2 ?
Marc Piechura
@marcpiechura
@raskolnikoov the Xunit version it targets ;-)
Lev Lehn
@llehn
@Cawifre thx
Daniel Söderberg
@raskolnikoov
can somebody who knows provide an example with Akka.Testkit where the childactors uses Context.DI.Props<T>() ? I get errors on this and dont know how to test my actors where it uses DI
System.NullReferenceException
Alex Valuyskiy
@alexvaluyskiy
@raskolnikoov there is no difference anymore. Both depend on Xunit2
Aaron Stannard
@Aaronontheweb
@raskolnikoov although not anymore - as of 1.2 both of them are the same essentially
we dropped support for XUnit1
Arsene T. Gandote
@Tochemey
Hello. I can see the akka stream is now stable. However there is no great documentation or tutorial around. Every time I have to go and read the JVM version and Tuto the JVM guys have put online. Please can you guys who has used well share some real world scenario tutorial that can help we novice in it.
Michael Chandler
@optiks
@Aaronontheweb any idea if the CreateTestProbe() behaviour change was deliberate? (see more detail above)
fanoI
@fanoI

Is it possible to launch the UI Event Loop from an Actor? Only if that Actor will exist the GUI should run this works with a Command Line application but not in Akka.Net Actor:

       [STAThread] //optional
        protected static bool StartUILoop()
        {
            Application.Run();
            return true;
        }

        protected override void PreStart()
        {
            /* Let's start an Empty UI Application, the true Application will load the page with "Loading..." */
            //Task mytask = Task.Run(() => Application.Run());

            Task mytask = Task.Run(() =>
                StartUILoop()
            );
        }

then when I receive the load command I simply do:

                    var form = new LoginForm();
                    form.Show();

the form is effectively shown but is not working is not active, label text is not drawn and if I move the mouse in it I get the spin wheel!

Thank you for your help...

I've tried to create the Actor in the UI thread using dispatcher = akka.actor.synchronized-dispatcher but nothing changes I suspect it is because I've created a Task not the normal UI thread
Marc Piechura
@marcpiechura
@Tochemey we have ported the complete documentation from the jvm too. Can you give me a link with the tutorials your referring to?
Arsene T. Gandote
@Tochemey

@Silv3rcircl3 I have gone through few of them.
https://www.slideshare.net/Lightbend/understanding-akka-streams-back-pressure-and-asynchronous-architectures?next_slideshow=1

https://www.slideshare.net/rolandkuhn/akka-streams-and-http

https://github.com/pkinsky/akka-streams-example

https://www.slideshare.net/joy87/a-dive-into-akka-streams-from-the-basics-to-a-realworld-scenario

The documentation is great. I am disputing that. However you gusy have used in production if you guys can write some tutos like the one Bartosz wrote on Akka.IO it will help us as starting point.

Marc Piechura
@marcpiechura
The example from pkinsky is probably worth porting it. I think the only one that is using Akka.Streams in production is @Aaronontheweb ;-) And we have the webcrawler example that is now using Akka.Streams, see petabridge/akkadotnet-code-samples@fcc6025
Aaron Stannard
@Aaronontheweb
@optiks the change was deliberate