Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 17:57
    valdisz synchronize #3904
  • 12:27
    valdisz synchronize #3904
  • 11:43
    cptjazz commented #3925
  • 11:40
    cptjazz synchronize #3925
  • 11:02
    valdisz edited #3904
  • 10:55
    Aaronontheweb synchronize #3926
  • 10:45
    Aaronontheweb opened #3927
  • 10:01
    valdisz synchronize #3904
  • 06:22
    cptjazz commented #3925
  • Sep 21 19:33
    Aaronontheweb opened #3926
  • Sep 21 16:19
    valdisz synchronize #3904
  • Sep 21 14:58
    Aaronontheweb synchronize #3924
  • Sep 21 14:58
    Aaronontheweb commented #3922
  • Sep 21 14:45
    valdisz synchronize #3904
  • Sep 21 14:43
    valdisz synchronize #3904
  • Sep 21 14:35
    Aaronontheweb commented #3925
  • Sep 21 09:51
    cptjazz opened #3925
  • Sep 21 09:11
    cptjazz opened #3924
  • Sep 20 23:30

    Aaronontheweb on dev

    added ability to support custom… (compare)

  • Sep 20 23:30
    Aaronontheweb closed #3923
Aaron Stannard
@Aaronontheweb
@MrTortoise yep, totally
via socket
Bartosz Sypytkowski
@Horusiath
@MrTortoise akka.io is actor abstraction over raw sockets. You basically can do every network I/O you want.
Aaron Stannard
@Aaronontheweb
@andreyleskov I think the debug flag is there for unit testing the EventBus itself
like inside Akka.NET's own internal tests
don't think there's a way to pass that in from the outside although I could be wrong
Bartosz Sypytkowski
@Horusiath
@garrardkitchen from the process itself, when actor system starts, you'll see logs which will tell you which on which ip:port actor system is listening. It's you want to build a cluster of connected actor systems, all you need is to know an address of single node that is already part of the cluster.
  • Common patters, is to havea 1-3 stub nodes with static well-known address, that other nodes will use to communicate.
  • Another approach is to use 3rd party service as rendezvous point for all nodes. This can be even a database table where nodes write down their own addresses to be easier to discover. I've created a very simplistic example of this using sqlite, however it's missing a case of hard system shutdown (registered addresses are never cleaned then).
@andreyleskov it would be hard to get debug logs about missing messages send from event bus, as event bus itself is a medium used to send log messages
John Nicholas
@MrTortoise
@Aaronontheweb @Horusiath thanks
Rajiv Mounguengue
@Rajivhost
Hi @Aaronontheweb @Horusiath, I don't see any plan for Akka.Http on the road map (https://petabridge.com/blog/akkadotnet-2015-roadmap/), nothing is coming for this?
Bartosz Sypytkowski
@Horusiath
@Rajivhost this has a low priority, as it's immense amount of work (it's been 2 years of work for 4 people), and even more work to maintain it. Since you can use akka.net with existing web frameworks, we want more to work on maturing existing plugins.
Rajiv Mounguengue
@Rajivhost
@Horusiath ok, understood!
Andrey Leskov
@andreyleskov
@Aaronontheweb @Horusiath I've found from code that flag is set from actor.debug.event-stream = on
Aaron Stannard
@Aaronontheweb
heyo
nice job @andreyleskov
Andrey Leskov
@andreyleskov
and have it configured, but did not get any logs 8(
now thinking about reasons and possibility how subscribers can miss messages, or die before it
btw event-stream setting is not described in documentation
Garrard Kitchen
@garrardkitchen
Thanks @Horusiath. This is my scenario (over simplified)....I've 2 ActorSystems; 1 website & 1 win service. I want the website to check if win service is extant (has started up and listening on an address). I've been using ActorSelection().ResolveOne but that comms with actual actor and seems a little heavy for what I want to do at that particular point in my workflow. I'm not using akka.cluster.
Bartosz Sypytkowski
@Horusiath
@garrardkitchen you probably need some third party to initialize connection. This can be database or queue i.e. actor system writing it's init endpoint in table or in messge bus.
Garrard Kitchen
@garrardkitchen
@Horusiath Ok, thanks.
Kevin Avignon
@Kavignon
With F#, I have a bind overload compiling issue which doesn't make any sense for me! The way I'm receiving the message seems pretty fine to me, can someone help me out please !
Kevin Avignon
@Kavignon
The problem is @ L58
I don't understand !
Bartosz Sypytkowski
@Horusiath
@Kavignon return! { state with Operation = Some Sell }return! handleProtocol { state with Operation = Some Sell }
actor expression needs to be tail recursive. Otherwise it will stop an actor after completing a message
Kevin Avignon
@Kavignon
Recursivity strikes back !
Been coding for way too long, sorry to bother ! But thanks for the amazing time response, was thinking I'd have a couple of hours of me looking again on internet :)
Bartosz Sypytkowski
@Horusiath
no problem ;)
Kevin Avignon
@Kavignon

Hey quick question for @Horusiath
Like I've mentioned a bunch of times, I'm creating a game prototype with Akka.NET
When I'll launch my game, how do properly start those actors?
I have these lines for instance
let system = System.create "system" <| Configuration.load ()
let shopSystem = spawn system "Shop System" <| itemStoreManager

That's the part that got me confused a bit at the moment.I'll give you some context on my architecture
I see the game as a huge state which has several smaller states such as where I am in the storyline or in what phase of the battle system am I in. The first thing I want to start is that state server which will be notified by every update and I will want to enter my shop, for instance, I will require the shop system to be either started, revived or unpaused ? I'm not sure about the terminology.
Thanks in advance :innocent:

Bartosz Sypytkowski
@Horusiath
you can have a top level manager actor, that you'll ask for get or create a component for me
if it's not clrear when to create it
Kevin Avignon
@Kavignon
That actor sole purpose would be to either get or create components ? Should it also have a child actor to listen to the event stream in case of dead letters which would mean that 1+ of my actors are dead and needs to be revived ?
By any chance, and I know they're pretty slim, is there an example with F# of clustering or a similar approach to clustering Akka.NET actors that you'd know of ? @Horusiath
Bartosz Sypytkowski
@Horusiath
if you need to be informed about actor dying, you can use Context.Watch to watch over that actor (in F# API this function was called monitor I suppose).
Wathing actor will receive Terminated message with reference to dead actor
there are few examples, but they are targetting Akkling -> my fork of Akka.FSharp
Siemienik Paweł
@Siemienik
Hi everyone, I've just started use Akka.Persistance and I am not sure how It should handle collection with 130 000 entities.`
Before i used mongodb driver without persistence
My first idea: there exists CollectionPersistenceActor, which handle update/insert/remove commands. Each command as a query works on mongodbdriver directly(update, insert, remove). But in that case, what should happend on snapshot()?
Siemienik Paweł
@Siemienik
Second idea: CollectionActor that can create/stop/remove children actors(EntityPersistenceActor) and sending to they proper commands(update/snapshotAndStop). Each children actor has own persistenceId used to respawn. After snapshot the EntityPersistenceActor will be stoped. When the actor is required, will respawn by persistenceId.
But in that case i dont know how can i quick searching and ordering.
Thanks a lot:)
Andrey Leskov
@andreyleskov
@Siemienik I'm using same approach to work with each domain entity (aggregate) as a separate actor. Supervisor (CollectionActor) will spawn childs and pass commands to them, also it should be responsible for child termination on inactivity.
you can check example here
Andrey Leskov
@andreyleskov
Guys, can a Pool router terminate one of its children?
Andrey Leskov
@andreyleskov
Answer is : yes, if pool use resizer
Kevin Avignon
@Kavignon
I'll take a look at it tonight ! @Horusiath
Thanks :D
Andrey Leskov
@andreyleskov
Guys, I'm continue to investigate issue with event bus not delivering messages to subscribers
I have two subscribers - one is actor with random pool, and it is always receiving messages