akkadotnet/akka.net

Port of Akka actors for .NET

Samuel Verstraete

@elangelo

or is there a WF alike functionality?

i don't need the visual stuff of it

just the persistence and the modularity

Tom Rathbone

@chillitom

@rogeralsing thanks, that's interesting, be great to see similar in akka.net ... happy to help out

Q: what's the correct way to configure custom serialization for Akka.Persistence? What interfaces should I implement?

Graeme Bradbury

@GraemeBradbury

@Aaronontheweb So from the logs I can tell that the process for the test runner completes.

process.WaitForExit() returns

Graeme Bradbury

@GraemeBradbury

If an actor is setup with Receive<T>( x => DoSomethingAsync(x)); am I right in thinking that DoSomethingAsync is not going to be observed?

it'll just be a fire and forget into the ether.

Bartosz Sypytkowski

@Horusiath

@chillitom every persistent journal backend may define it's own set of queries, you may use to get overall information across multiple persistent ids

this is in fact what sql-based journals will support soon

Bartosz Sypytkowski

@Horusiath

and when it comes to serializers:

You need to create your own serializer inherinting from Akka.Serialization.Serializer it has to have unique Id in scope of an actor system
You'll need to register it in HOCON config using i.e. akka.actor.serializers.my-serializer-alias = "MyNamespace.MySerializerClass, MyAssembly"
Bind it to particular type of message in HOCON using akka.actor.serialization-bindings { "MyNamespace.MyClass, MyAssembly" = my-serializer-alias }. This binding is inheritance-sensitive and you may apply it to interface, that you can later use to mark each particular data type to be serialized/deserialized with your custom serializer

Tom Rathbone

@chillitom

@Horusiath would there be a way I could bind it to all F# discriminated unions?

Bartosz Sypytkowski

@Horusiath

unfortunatelly not, as discriminated unions don't have single common interface or root. But i.e. you could attach an interface like that:

type MyUnion =
    | A
    | B
    interface ISerializeWithFlatBuffers

Thomas Lazar

@thomaslazar

trying to get a test to log stuff out with nlog so i can see what stuff is happening. but i can't seem to get it to work. did i do anything wrong there?

        public SearchIndexMasterTest()
            : base(@"
                    akka.loglevel = INFO
                    loggers = [""Akka.Logger.NLog.NLogLogger, Akka.Logger.NLog""]
        ")
        {
        }

i have a nlog.config and stuff. and on my web project it's working. just not on the test.

nevermind... i was stoopid

forgot the "akka." before "loggers"

Christian Duhard

@cduhard

@Horusiath I will try it as soon as a new release is up

@Hori

@Horusiath it's definitely broken right now. When a lot of messages are processed quickly the state doesn't get updated until a pause in messages throughput

Christian Duhard

@cduhard

Have there been any memory leak issues?

Thomas Lazar

@thomaslazar

can i specify more then one logger in akka? when i change the logger in my tests to nlog it removes the stdout logger and the EventFilter thing seems to break

Christian Duhard

@cduhard

does the Scheduler leak memory by chance?

Christian Duhard

@cduhard

ScheduledWork is steadily consuming memory

Christian Duhard

@cduhard

my service runs out of memory just sitting idle running a few repeating schedules in parallel

Aaron Stannard

@Aaronontheweb

@GraemeBradbury if the lambda in the Receive<T>(async x => DoSomethingAsync(x)) then the actor will use its async await

looks like all of the specs that have had high failure / repro rates are ones that use Ask or TPL

Graeme Bradbury

@GraemeBradbury

@Aaronontheweb That'll halt processing of messages until the await returns?

Aaron Stannard

@Aaronontheweb

correct

all of this started happening after I upgraded the build server - doesn't look like it was any of the PRs.... I wonder if RyuJIT is running under the covers

Graeme Bradbury

@GraemeBradbury

You upgraded to VS2015 right?

Aaron Stannard

@Aaronontheweb

yep

Graeme Bradbury

@GraemeBradbury

I'm pretty sure that'll turn ryujit on.

Aaron Stannard

@Aaronontheweb

works locally for me though, using MSBuild from 2015

Graeme Bradbury

@GraemeBradbury

Same here. I get no test failures but push it to the build server and I get unit tests failing.

Driving me up the wall.

Aaron Stannard

@Aaronontheweb

tell you what

I'll fire up a build agent manually and give you some RDP credentials

you should be able to do stuff like remote debugging on it

Graeme Bradbury

@GraemeBradbury

no rush, won't be able to do much till kids are asleep in ~3hours.

Aaron Stannard

@Aaronontheweb

firing one up now

going to intentionally not let it connect to TeamCity

but you can still go into it and git clone + build stuff

Graeme Bradbury

@GraemeBradbury

thanks

Aaron Stannard

@Aaronontheweb

it's running the exact same configuration as the agents

although it might be a little slow for you to connect since the server is in Texas :p

Tom Rathbone

@chillitom

@cduhard can you give some more information about what you're trying to do?

Christian Duhard

@cduhard

I am using akka persistence

Where communities thrive

People

Repo info

Activity