These are chat archives for akkadotnet/akka.net

5th
Apr 2017
Weston
@ronnyek
Apr 05 2017 03:34
anyone alive?
I've got more questions regarding .io and streams
Arjen Smits
@Danthar
Apr 05 2017 12:24
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
Apr 05 2017 13:18
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
Apr 05 2017 13:21
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
Apr 05 2017 13:24
@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
Apr 05 2017 13:25
Try to work out an example and get that working first
its probably something in your hocon config
Jay DeBoer
@jaydeboer
Apr 05 2017 13:25
That is what I am doing. :)
Arjen Smits
@Danthar
Apr 05 2017 13:25
:+1:
Weston
@ronnyek
Apr 05 2017 13:37
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
Apr 05 2017 13:43
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
Apr 05 2017 13:44
the current dev ? or 1.1.2 ?
Weston
@ronnyek
Apr 05 2017 13:44
1.1.3
Arjen Smits
@Danthar
Apr 05 2017 13:44
There has been quite some work on akka.io that should yield some improvements for the upcoming 1.2 release
Weston
@ronnyek
Apr 05 2017 13:45
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
Apr 05 2017 13:46
@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
Apr 05 2017 13:47
@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
Apr 05 2017 13:48
k
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
Apr 05 2017 13:53
thats seems... wrong. I know for a fact some people have reached way higher numbers with older versions of akka.io.
We have a ping pong benchmark somewhere that uses akka.io
hang on while i look it up
Weston
@ronnyek
Apr 05 2017 13:57
well let me backup
I'm not trying to talk between akka.net io and akka.io
I'm just trying to handle raw tcp connections
if thats not what you thought
Arjen Smits
@Danthar
Apr 05 2017 13:58
ok
should not be an issue though
Weston
@ronnyek
Apr 05 2017 14:05
k
yeah Iwouldnt think it was
but if it seems like I got the wrong idea about all this
eg, akka wouldnt be a good fit here or whatever
I thought akka would be awesome for all the reactive stream processing as well as the backpressure stuff
Arjen Smits
@Danthar
Apr 05 2017 14:06
Akka.streams certainly is
@Silv3rcircl3 we don't have an integration for akka.io yet do we ?
Alex Valuyskiy
@alexvaluyskiy
Apr 05 2017 14:07
Not yet
waiting for akkadotnet/akka.net#2405
Weston
@ronnyek
Apr 05 2017 14:49
io is high performance network transports and things like http endpoints and what not?
webeoutrascoisas
@webeoutrascoisas
Apr 05 2017 15:18
Hi!
There's a way to test if my ActorSelection received a message? Something like ActorSelectionProbe?
Chris G. Stevens
@cgstevens
Apr 05 2017 16:18
@webeoutrascoisas I am returning a ACK in cases where I need to guarantee delivery.
Nick Chamberlain
@heynickc
Apr 05 2017 16:29
@webeoutrascoisas are you able to create a TestProbe at that specific path? That test probe could then forward, if needed.
webeoutrascoisas
@webeoutrascoisas
Apr 05 2017 16:39
i'll try it @heynickc
webeoutrascoisas
@webeoutrascoisas
Apr 05 2017 16:53
TestProbe ExpectMsg still not working
I'm passing Ref.Path to Context.ActorSelection
Jeff Pang
@jeff-pang
Apr 05 2017 16:59
can someone point me in the right direction on how to get Akka on .net core? The information i got from google all seems to be dated. those I found uses project.json
webeoutrascoisas
@webeoutrascoisas
Apr 05 2017 17:00
@jeff-pang there's no .net core version yet
Jeff Pang
@jeff-pang
Apr 05 2017 17:04

@webeoutrascoisas thanks. I understand that officially not from nuget but based on some article you are able to get an "unofficial" version to work since 1.2.0-alpha1 ? Or am I mistaken?

I read it from here https://medium.com/@FurryMogwai/building-a-basket-micro-service-using-asp-net-core-and-akka-net-ea2a32ca59d5

Marc Piechura
@marcpiechura
Apr 05 2017 17:26
@webeoutrascoisas @jeff-pang it's available via myget , link is somewhere in #2153
Jeff Pang
@jeff-pang
Apr 05 2017 17:40
@Silv3rcircl3 awesome! Thanks!
Deniz ─░rgin
@Blind-Striker
Apr 05 2017 20:16

@Silv3rcircl3 i couldnt find akka core library in myget. So i download @alexvaluyskiy https://github.com/alexvaluyskiy/akka.net/tree/coreclr_final branch and compile it myself for todays meetup. Because of Google.ProtocolBuffers library i couldnt compile cluster and remote to .net core but Akka.Core local actor system can work on .net core.

I made an example repo ;

https://github.com/CodeFiction/AkkaDotNetCoreDemo

Deniz ─░rgin
@Blind-Striker
Apr 05 2017 20:23
I think I convinced most of the developers who participated in today's meeting to use Akka.Net :)
Sean Gilliam
@sean-gilliam
Apr 05 2017 21:43
nice :+1: