@andreyleskov I don't know, if you companion plugins have nightly builds, but the best way is to check it out
@Horusiath thank you for your answer. The akka documentation says to serialize the atleastoncedeliverysnapshot in a byte array, and I tried also protobuf-net but it requires all type and subtype to be mapped beforehand. This is not possible because i canot know the kind of messages that the snapshot will contain inside beforehand. So how can i serialize that kind of object? How does akka.net manage this thing internally? Does it ever serialize object in a byteArray ?
@ayoung you're trying to send a message to remotely deployed actor by pinning it to a router, this sounds like overcomplicating things
@NicolaAtorino you can try to use Wire serializer (which will we the default serializer from v1.5 anyway) or just use something json-based
btw. what's wrong with serializing atleastoncedelivery snapshots right now?
@Horusiath we are using a custom serializer instead of wire because we have elastic as a persistence db (wire serialized object do not work well with it), and this custom serializer has problems with the snapshot object (especially, the actorPath subtype)
@Horusiath since i need my own state obj as a wrapper around the snapshot, i was following the documentation that ways to store the snapshot as a byteArray in a property of my own stateobj. And that's the reason i needed a bynarySerialization in the first place
but now i am thinking that instead of using a byteArray i can store it as a string, and use explicitly the wireserialization that should be able to work with that.
every akka serializer is capable of serializing object ot byte arrays
even if you have stream serializers, you can sent them MemoryStream and get byte array from it
in fact now i will try to use programmatically the ActorSystem.Serialization class
it works well. thank you @Horusiath
np ;)
@Horusiath Ended up using XUnit and I can run parallel test from different assemblies so it solve what I was trying to do
Web crawler sample documentation says: "You also want to make sure you include your Akka.NET HOCON configuration inside Web.config, that way you can take advantage of Web.config Configuration Transformations in combination with HOCON."
is it actually possible to do config transforms on the HOCON?
@dandago2_twitter Not sure if you can do transformations inside the hocon, but you can always replace the whole section with another hocon...
that's kind of radical, it's like saying replace a whole Web.config with another... but good point
it would be nice to be able to tweak specific properties per environment
@dandago2_twitter What i have done is provide a base config in the normal hocon config section
and during app initialisation provide the override or fallback facilities of the hocon config system, to replace or inject environment specifics
these specifics can then be provided through any means you want. I use an app-setting and have my deployment CI env put in the right stuff during deployment.
ofcourse, if your deployment env can substitute variables in your config, you can do that with the whole base hocon config as well ofcourse
but i like to keep a seperation between the base stuff that applies to all instances, and the env specific stuff
that's a really interesting approach; is there an example somewhere of how to do these overrides?
@dandago2_twitter
hoconConfig.WithFallback(fallbackHoconConfig)
if some key was not found in
hoconConfig, it will be searched in fallbackHoconConfig
typically we put HOCON in the Web.config and it gets pulled automatically, so where does that hoconConfig part actually go?
where ever you want
you could put it in an appsetting value in your config
and read it from there
when you're creating actor system by
ActorSystem.Create("sys") this is actually a shorter form of ActorSystem.Create("sys", ConfigurationFactory.Load()) which loads config from web.config
I have some issues with TestKit and xunit console runner. When I run my tests through VS they pass fine, but when using the console runner (as my CI tool does) they fail. The tests cases are basically doing the following:
- Create an actor, 2. Send it a message, 3. Expect another message back to the TestActor.
When running the tests through the console, I observe that the message sent in step 2 is unhandeled:
[WARNING][2016-10-07 13:29:56][Thread 0005][akka://test/user/$c] Unhandled message from [akka://test/user/testActor1#360950702]: Common.Models.Messages.Worker.Parse
And that basically causes the test to fail. Would that indicate that the message is sent before the actor under test has been created?
does it always fail ? or intermittenly ?
Actually, never mind, I think it is a bug in my application code... :(
ok
Any way I could do a test with an assert like
ExpectOneMsg<Foo>()?
To check that I don't receive multiple instances of the Foo message
@peter-bannerflow ExpectMsg + ExpectNoMsg or ReceiveWithin and then check the result
Ah I see, that could work, thanks
@Horusiath let me try to clarify a bit. my actor hierarchy is a bit like this
hashPool -> process actors -> broadcastGroup. The hash pool at the top is what complicates things because it remotely deploys the process actors. that is what makes the actor selection so difficult for me to configure for the broadcast group.
Has anyone done anything using redis, specifically, subscribing to a channel and receiving messages in actors. I'm trying to communicate between a JavaScript application and a backend written using Akka.net actors. Any help appreciated.
@ayoung to be honest I've never seen real use case scenario for consistent hash pool and 90% of the people trying it was actually misused it
@SeanFarrow I have used the stackexchange redis client. Could not get the connection multiplexer to work properly inside an actor.
Dont know why, the multiplexer just didn't like it.
But i have not used channels. What i do though is setup the connection outside of an actor, and pass it in as a reference to an actor.
But what you can do is receive messages from your channel, and then send them into your actor system via an IActorRef
Does that help ?
@danthar, possibly I'll take a look. I was hoping to use Akka.Streams, but it seems that client won't allow me to, or will certainly have issues. I will have a lot of channels, So I need to work out whether one actor will do the trick or multiple actors are needed. The actors are sending back to a SocketIO node api.