Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 02:22
    kimbyungeun opened #4098
  • Dec 15 19:47

    Aaronontheweb on dev

    TypeExtensions.TypeQualifiedNam… (compare)

  • Dec 15 19:47
    Aaronontheweb closed #4071
  • Dec 15 19:47
    Aaronontheweb closed #3767
  • Dec 15 19:47
    Aaronontheweb labeled #3767
  • Dec 15 19:47
    Aaronontheweb labeled #3767
  • Dec 15 19:47
    Aaronontheweb milestoned #3767
  • Dec 15 19:44
    Aaronontheweb labeled #4097
  • Dec 15 19:44
    Aaronontheweb milestoned #4097
  • Dec 15 13:23
    Aaronontheweb commented #4096
  • Dec 15 13:22
    Aaronontheweb commented #4093
  • Dec 15 13:16
    ismaelhamed commented #4093
  • Dec 15 13:04
    ismaelhamed edited #4097
  • Dec 15 13:04
    ismaelhamed opened #4097
  • Dec 15 12:50
    ismaelhamed commented #4096
  • Dec 15 12:48
    ismaelhamed commented #4096
  • Dec 15 12:05
    Aaronontheweb commented #4096
  • Dec 15 11:43
    ismaelhamed commented #4096
  • Dec 14 19:13
    hwanders commented #4096
  • Dec 14 13:05
    IgorFedchenko commented #4085
Aaron Stannard
@Aaronontheweb
@Silv3rcircl3 yeah, the FlowInterleave specs implement a base class but the others do not
got 13 totally different random specs to fail this time
in Akka.Streams
so I think that it's something across the board with the DSL compiler
or at least something we're using to test it
dammit Mono
why you have to be so weird
Marc Piechura
@marcpiechura
I see, I really have no idea. @alexvaluyskiy mentioned that https://github.com/akkadotnet/akka.net/blob/ade2176dd5c1342d248c2a06bb72c81a8add18c8/src/core/Akka.Streams/Dsl/Keep.cs will not work on .netcore and since it contains some generic edge case stuff it's maybe worth a shot
Maybe the part that is missing on netcore is also not implemented on mono
Maciek Misztal
@mmisztal1980
@Aaronontheweb In a cluster: when a role-leader goes down and a new one gets elected, is there an event that signals it?
Aaron Stannard
@Aaronontheweb
yep
RoleLeaderChanged
can subscribe to it in the gossip
@Silv3rcircl3 looks like it's something being passed into Props
during actor system startup
Maciek Misztal
@mmisztal1980
does it contain role name information?
Aaron Stannard
@Aaronontheweb
Maciek Misztal
@mmisztal1980
awesome, cheers!
Aaron Stannard
@Aaronontheweb
@Silv3rcircl3 weird.... weird... weird
private LocalActorRef CreateSystemGuardian(LocalActorRef rootGuardian, string name, LocalActorRef userGuardian)     //Corresponds to Akka's: override lazy val guardian: systemGuardian
        {
            return CreateRootGuardianChild(rootGuardian, name, () =>
            {
                var props = Props.Create(() => new SystemGuardianActor(userGuardian), _systemGuardianStrategy);

                var systemGuardian = new LocalActorRef(_system, props, DefaultDispatcher, _defaultMailbox, rootGuardian, RootPath/name);
                return systemGuardian;
            });
        }
this is the culprit
according to the stack trace
Ronnie Overby
@ronnieoverby
I created and configured a custom priority mailbox and I see akka is instantiating it, but the PriorityGenerator method is never called
Aaron Stannard
@Aaronontheweb
but, this line of code is literally called in the setup of every AkkaSpec
Ronnie Overby
@ronnieoverby
Can someone help me with that?
Maciek Misztal
@mmisztal1980
btw, I'd like to do some mono builds with Akka, do you have any good material on how to get started with building stuff on mono? anything special I need to pay attention to ?
Aaron Stannard
@Aaronontheweb
@ronnieoverby sure thing, mind posting a copy of your mailbox
@mmisztal1980 biggest thing: always use the Path class to construct your paths
the / and \ stuff will drive you insane
Ronnie Overby
@ronnieoverby
    public class Mailbox : UnboundedPriorityMailbox
    {
        public Mailbox(Settings settings, Config config) : base(settings, config)
        {                
        }

        protected override int PriorityGenerator(object message)
        {
            if (message is Unsubscribe || message is Subscribe)
                return 0;

            return 1;
        }
    }
Aaron Stannard
@Aaronontheweb
and this isn't getting called?
running 1.1.1 right?
Ronnie Overby
@ronnieoverby
Correctimundo
<package id="Akka" version="1.1.1" targetFramework="net45" />
Aaron Stannard
@Aaronontheweb
(we changed all of the mailbox loading stuff in 1.1)
ok
Ronnie Overby
@ronnieoverby
I couldn't get it to use it with HOCON
Aaron Stannard
@Aaronontheweb
let me take a look at my spec real quick
Ronnie Overby
@ronnieoverby
but using .WithMailbox I see akka call the ctor of the mailbox
Aaron Stannard
@Aaronontheweb
hmmm
HOCON wouldn't load it?
using the FQN?
Ronnie Overby
@ronnieoverby
no, but that's a different story
I did register the type/key with hocon
and I refer to "pubsub-mailbox" when calling .WithMailbox
off of the props
Maciek Misztal
@mmisztal1980
but in order to build a project I basically need to run xbuild on a .sln file, with normal .NET 4.6 references?
or .NET 4.5.2 ?
Aaron Stannard
@Aaronontheweb
@mmisztal1980 .NET 4.6.1 will work
so anything up to that