akkadotnet/akka.net

Port of Akka actors for .NET

Daniel D'Agostino

@dandago2_twitter

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

Arjen Smits

@Danthar

@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

Daniel D'Agostino

@dandago2_twitter

that's a really interesting approach; is there an example somewhere of how to do these overrides?

Bartosz Sypytkowski

@Horusiath

@dandago2_twitter hoconConfig.WithFallback(fallbackHoconConfig)

if some key was not found in hoconConfig, it will be searched in fallbackHoconConfig

Daniel D'Agostino

@dandago2_twitter

typically we put HOCON in the Web.config and it gets pulled automatically, so where does that hoconConfig part actually go?

Arjen Smits

@Danthar

where ever you want

you could put it in an appsetting value in your config

and read it from there

Bartosz Sypytkowski

@Horusiath

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

Peter Bergman

@peter-bannerflow

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?

Arjen Smits

@Danthar

does it always fail ? or intermittenly ?

Peter Bergman

@peter-bannerflow

Actually, never mind, I think it is a bug in my application code... :(

Arjen Smits

@Danthar

Peter Bergman

@peter-bannerflow

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

Marc Piechura

@marcpiechura

@peter-bannerflow ExpectMsg + ExpectNoMsg or ReceiveWithin and then check the result

Peter Bergman

@peter-bannerflow

Ah I see, that could work, thanks

Andrew Young

@ayoung

@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.

Sean Farrow

@SeanFarrow

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.

Bartosz Sypytkowski

@Horusiath

@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

Arjen Smits

@Danthar

@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 ?

Sean Farrow

@SeanFarrow

@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.

Peter Bergman

@peter-bannerflow

@Danthar I am also using the stackexchange redis client and it seem to work fine. I create a static ConnectionMultiplexer reference in my main service class where I boot up my actor system, then I do GetDatabase() calls on that reference from inside my actors

Marc Piechura

@marcpiechura

@SeanFarrow out of curiosity, why aren't you allowed to use streams?

Sean Farrow

@SeanFarrow

All Conversations

Activate or click this element to toggle the profile menu

Favourites

People

akkadotnet

•

Home

•

Billing

•

Get Gitter Apps

•

Allow Private Repo Access

•

Sign Out

Add a room

akka.net

Leave

Hide

Your Suggestions


SuaveIO/suave

aurelia/Discuss

akka/akka

mono/mono

dotnet/corefx

dotnet/coreclr

akka-bootcamp

helios-io/helios

IdentityServer3

visualfsharp

TypeScript

Rx.NET

Your Organisations

Twitterizer

I'm not saying I'm not allowed to use streams, the way the StackExchange Redis subscription system works doesn't lend itself to doing so though!

Marc Piechura

@marcpiechura

Ahhh :) I thought client = customer ;)

Sean Farrow

@SeanFarrow

@Silv3rcircl3 It's nots that simple! I think I've fiund a solution, when I validate it, I'll let you know--you never know, I might release it as open source!

All Conversations

Activate or click this element to toggle the profile menu

Favourites

People

akkadotnet

•

Home

•

Billing

•

Get Gitter Apps

•

Allow Private Repo Access

•

Sign Out

Add a room

akka.net

Leave

Hide

Your Suggestions


SuaveIO/suave

aurelia/Discuss

akka/akka

mono/mono

dotnet/corefx

dotnet/coreclr

akka-bootcamp

helios-io/helios

IdentityServer3

visualfsharp

TypeScript

Rx.NET

Your Organisations

Twitterizer

It's not that somple. I think I've got a solution though, when I find one, I'll let you know!

Marc Piechura

@marcpiechura

@seanfarrow let me know if you need some help. Also maybe my Azure adapter can give you some inspiration, don't know how Redis works but maybe it helps https://github.com/Silv3rcircl3/Akka.Streams.Azure

Aaron Stannard

@Aaronontheweb

boy, I've missed a lot of messages in here

vacation and doing remote work :p

In the UK at the moment; should be here through the end of the next week

but will go through all of this once I'm back

probably going to do a small point release soon with some minor Streams bug fixes, fixes for the priority mailbox, and others

also thinking about sending in a PR to skip some of the specs we know to be broken like the ClusterClient specs

no point in just re-running stuff repeatedly when the thing under test doesn't work

there's some specs, like the ActorsLeakSpec in Akka.Remote, that are just super complicated and can time out when things get busy... which makes me think maybe I should $$$ and increase the size of our VMs

Peter Bergman

@peter-bannerflow

When running an Akka.Cluster, is there any way for an actor in an actor system that has joined the cluster to get information about the number of nodes that joined the cluster with a specific role? I am just interested in the count nothing more than that

Aaron Stannard

@Aaronontheweb

@peter-bannerflow yep, Cluster.State will have that data

basically just iterate over all members and select them by their role

Peter Bergman

@peter-bannerflow

Nice, perfect :)

Where communities thrive

People

Repo info

Activity