Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 15:26
    IgorFedchenko synchronize #3973
  • 15:20
    IgorFedchenko synchronize #3973
  • 14:54
    IgorFedchenko synchronize #3973
  • 14:49
    IgorFedchenko synchronize #3973
  • Oct 22 21:12
    Aaronontheweb commented #4001
  • Oct 22 21:11

    Aaronontheweb on dev

    Added missing Persistence Testiā€¦ (compare)

  • Oct 22 21:11
    Aaronontheweb closed #4001
  • Oct 22 20:59
    sean-gilliam commented #3889
  • Oct 22 20:59
    sean-gilliam opened #4001
  • Oct 22 16:07
    spankr commented #3921
  • Oct 22 15:55
    Aaronontheweb labeled #3765
  • Oct 22 15:54
    Aaronontheweb labeled #3765
  • Oct 22 15:54
    Aaronontheweb milestoned #3765
  • Oct 22 15:53
    Aaronontheweb closed #3902
  • Oct 22 15:23
    Aaronontheweb commented #3921
  • Oct 22 15:11
    spankr commented #3921
  • Oct 22 15:05
    Aaronontheweb commented #3973
  • Oct 22 15:05
    Aaronontheweb commented #3973
  • Oct 22 15:02
    Aaronontheweb commented #4000
  • Oct 22 15:02
    Aaronontheweb milestoned #4000
eyantiful
@eyantiful
asking the router for GetRoutees returns empty while not ready ....
Bart de Boer
@boekabart
@mrn-aglic I always add unit tests for all types that need over-the-wire serialization, that tests their ability to be (de)serialized (and correctly so)
Using this helper:
public static class SerializerTestHelpers
    {
        public static async Task<T> AkkaSerialized<T>(this T src)
        {
            var hokon = "akka.actor.provider = \"Akka.Remote.RemoteActorRefProvider, Akka.Remote\"" +
                        Environment.NewLine +
                        "akka.remote.helios.tcp.port = 0" + Environment.NewLine +
                        "akka.remote.helios.tcp.hostname = localhost";
            var sys = ActorSystem.Create("src");//, ConfigurationFactory.ParseString(hokon));
            await sys.Terminate();
            var ser = sys.Serialization.FindSerializerFor(src);
            var bin = ser.ToBinary(src);
            return (T)ser.FromBinary(bin, typeof(T));
        }
    }
Bart de Boer
@boekabart
If you use a different-than-default serializer, you configure it in the hokon string as you do for your application.
So you instantiate your class, then call .AkkaSerialized() on it, and compare the resulting output (if not an exception ;) ) with the input version. Should be equal enough for your use case.
Damian Reeves
@DamianReeves
@boekabart thats a nice and straightforward utility method
Bart de Boer
@boekabart
Just notice now that the hokon is not used in the code ;)
commented out
Damian Reeves
@DamianReeves
Hey guys I've been looking at Akka.Interfaced, but before I dive headlong into making interface contracts for all my actors I wanted to know how everyone else manages the needs to have contracts/protocols for their actors so that they are approachable by all members of the team. I'm assuming Akka.Interfaced is not that widely used (but it does give you nice Orleans style interfaces to code against)
Ismael Hamed
@ismaelhamed
When deleting events from the EventJournal in Akka.Persistence.SqlCommon, has the IsDeleted column any use anymore?
Ronnie Overby
@ronnieoverby
@Aaronontheweb akkadotnet/akka.net#2308
Bartosz Sypytkowski
@Horusiath

@DamianReeves in Akka (and other message based models) it's easier to define a contract on message level, i.e:

interface IMyProtocolMessage {}
sealed class MyMessage1 : IMyProtocolMessage {}
sealed class MyMessage2 : IMyProtocolMessage {}

Unlike method calls, messages are composable. You can wrap one message with another, batch them, redirect or persist if necessary. Also, you can define dynamic interfaces (through Become) with that.

For type safety it's possible to wrap IActorRefs with typed version (think IActorRef<IMyProtocolMessage>) - I've made this a default in Akkling.

Damian Reeves
@DamianReeves
Hmm... that makes sense. So @Horusiath when you store IActorRefs in your actor implementations you store IActorRef<T>s so that that lets you know what set of messages you can send?
Bartosz Sypytkowski
@Horusiath
yes, I use custom surrogate wrapper over existing one
which contains type parameter
Damian Reeves
@DamianReeves
Cool, will crack open Akkling and take a look. I was starting to feel like the whole Akka.Interfaced approach was solving one problem but eliminating some of the benefits of a message oriented app model
Bartosz Sypytkowski
@Horusiath
Akkling is in F# - in C# you can do a little more (F# doesn't allow you do explicitly define covariant/contravariant types)
Damian Reeves
@DamianReeves
So what is the role of the TypedActorRefSurrogate<'Message>, is that for serialization purposes?
Bartosz Sypytkowski
@Horusiath
yes, actor refs need to have their own custom serialization/deserialization strategy - they are not serializable/deserializable without context. This is where surrogates come to play.
Damian Reeves
@DamianReeves
Ok, will have to look at examples of Akka's serialization surrogate usage. I like the pattern
Vagif Abilov
@object
When using F# API and piping an async task, where should a client catch possible task cancellation exception?
I.e. if the code looks like
doSomethingAsync |!> mailbox.Self
And doSomethingAsync is cancelled
How does this cancellation propagated to an F# actor function?
Bartosz Sypytkowski
@Horusiath
@object not tested but I guess it should be Failure message with TimeoutException inside
Ronnie Overby
@ronnieoverby
Messages are not copied when being passed between local actors, correct?
Vagif Abilov
@object
@Horusiath Failure message? What kind of message is it? Where is it defined?
Marc Piechura
@marcpiechura
@ronnieoverby correct, that's also the reason why your messages need to be immutable
Ronnie Overby
@ronnieoverby
Which is why I'm asking :)
Marc Piechura
@marcpiechura
;)
Ronnie Overby
@ronnieoverby
I'm adapting some legacy code to akka and was thinking about reusing some existing poco types that aren't immutable.
But doesn't look like that's a good idea.
Marc Piechura
@marcpiechura
Yeah would probably lead to some race conditions especially if you have lists and so on in your messages
You could maybe use a base actor that does deep coping like orleans does but that would slow down all the things
Ronnie Overby
@ronnieoverby
I don't have a big problem with writing mapping code to an immutable type
Marc Piechura
@marcpiechura
@object If the F# operator is using the normal PipeTo extension method then it's Status.Failure, see https://github.com/akkadotnet/akka.net/blob/dev/src/core/Akka/Actor/PipeToSupport.cs#L32
Vagif Abilov
@object
@Silv3rcircl3 yes it's using the normal PipeTo. Thanks for the link. Now it's clear.
Damian Reeves
@DamianReeves
Since messages are supposed to be immutable why is it that we don't see more examples of using structs as message types. @Horusiath I looked at your AkkaCqrs example again and you are using structs, was that just an experiment, or is that how you commonly proceed?
Damian Reeves
@DamianReeves
Can my ActorSystem be run in Azure in a Web job?
qwoz
@qwoz
You can run arbitrary .exe files in a web job, so theoretically I don't see why not. As to whether you ought to... :)
Bartosz Sypytkowski
@Horusiath
@DamianReeves my CQRS example is slightly outdated. Regarding structs this won't help a lot (I think), because messages bo through untyped mailbox so structs will be boxed anyway.
regarding web jobs - it's possible, I know that problem may be with exposing enpoint in cluster scenarios
Shuffzord
@Shuffzord
Hey guys, is there any room for some technical help in c# akka.net ?
Bart de Boer
@boekabart
stackoverflow, of course, and this room.
Shuffzord
@Shuffzord
I'm trying to setup nlog to be default logger for akka.net. I've included entries in config. loggers = ["Akka.Logger.NLog.NLogLogger, Akka.Logger.NLog"] with proper (i think) nlog entries but i still get buslogger as the default logger. How can i debug what config is used for system creation and what logger is picked?
Shuffzord
@Shuffzord
To add more depth to the qeustion. I tried to create cluste rsystem with and without explicit config var section = (AkkaConfigurationSection)ConfigurationManager.GetSection("akka"); var system = ActorSystem.Create("webcrawler2"); ClusterSystem = ActorSystem.Create("webcrawler", section.AkkaConfig);
In both cases, cluster system in its 'settings' has loggers with 1 entry of nlog but the Logger of cluster system is set us buslogger
Bartosz Sypytkowski
@Horusiath
@Shuffzord what exact path for loggers config did you use?
Shuffzord
@Shuffzord

@Horusiath this is from my config file. Akka: <akka> <hocon> <![CDATA[ akka { loglevel = DEBUG loggers = ["Akka.Logger.NLog.NLogLogger, Akka.Logger.NLog"] log-config-on-start = on } ]]> </hocon> </akka>

And configsections deifinition

    <section name="akka" type="Akka.Configuration.Hocon.AkkaConfigurationSection, Akka" />
    <section name="nlog" type="NLog.Config.ConfigSectionHandler, NLog"/>
    <section name="entityFramework" type="System.Data.Entity.Internal.ConfigFile.EntityFrameworkSection, EntityFramework, Version=6.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" requirePermission="false" />
    <!-- For more information on Entity Framework configuration, visit http://go.microsoft.com/fwlink/?LinkID=237468 -->
  </configSections>

And nlog section

<nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" autoReload="true" throwExceptions="true" internalLogFile="C:\Temp\internal_log_file.txt" debug="true" internalLogLevel="Trace"> <targets> <target name="f1" xsi:type="File" fileName="Scrapper.logfile" layout="[${date}] [${threadid}] [${message}]" /> <target name="c" xsi:type="Console" layout="[${threadid}] [${message}]" /> </targets> <rules> <logger name="*" writeTo="f1" /> <logger name="*" writeTo="c" minlevel="DEBUG" /> </rules> </nlog>

tried to create actiorsystem in following ways
var section = (AkkaConfigurationSection)ConfigurationManager.GetSection("akka"); var system = ActorSystem.Create("webcrawler2"); ClusterSystem = ActorSystem.Create("webcrawler", section.AkkaConfig);
As i see, first version is basically what is done is original source code

Ohh and getting logger is private readonly ILoggingAdapter _logger = Context.GetLogger();