akkadotnet/akka.net

Port of Akka actors for .NET

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

Jay DeBoer

@jaydeboer

@Danthar That is what I was expecting. I am using snapshots, and that does not appear to work. Maybe I will try convert over to eventsource to see if that works. At least then I know it has to do with snapshots, and not persistence in general.

@Danthar And thanks for the quick reply! :)

Arjen Smits

@Danthar

Try to work out an example and get that working first

its probably something in your hocon config

Jay DeBoer

@jaydeboer

That is what I am doing. :)

Arjen Smits

@Danthar

:+1:

Weston

@ronnyek

Basically what I'd ultimately like is something like the up example of telnet listener that I can pump gobs of data through. I've got that working though seem to hit contention...

If I could then take data from that listener and make that the source for reactive shit... Even better

Weston

@ronnyek

I dont have a TON of experience with akka, but basically followed what I understood in that example for the tcp listener stuff... and seemed like it really wasnt processing that many messages.

Arjen Smits

@Danthar

the current dev ? or 1.1.2 ?

Weston

@ronnyek

1.1.3

Arjen Smits

@Danthar

There has been quite some work on akka.io that should yield some improvements for the upcoming 1.2 release

Weston

@ronnyek

well I think my point was more I probably have it setup wrong =)

other thing is, I get my bytestrings on the other side, but I really dont know how to do anything with them. I get why there are bytestrings, but are there helpers to read stuff out of them like binaryreader/binary writer?

Jay DeBoer

@jaydeboer

@Danthar So it all works just fine using Journal, but snapshot without any HOCON does not appear to work in TestKit. Anyone else with any ideas how to configure a unit test to use something in memory for snapshots?

Arjen Smits

@Danthar

@ronnyek no. The bytestring is just an abstraction we adopted from the JVM. Mainly for serialization purposes, but its nothing more then a byte array underneath. So you can easily access that and use standard .net API's for reading byte arrays

Weston

@ronnyek

I'm writing as fast as I can, and built a little observable on the listener that avgs bytes per second

and the most I see is 256 bytes/sec

the client is attempting to write as fast as it can

Arjen Smits

@Danthar

thats seems... wrong. I know for a fact some people have reached way higher numbers with older versions of akka.io.

Where communities thrive

People

Repo info

Activity