Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 06:51

    dependabot-preview[bot] on nuget

    (compare)

  • 06:51
    dependabot-preview[bot] closed #4041
  • 06:51
    dependabot-preview[bot] commented #4041
  • 06:51
    dependabot-preview[bot] labeled #4051
  • 06:51
    dependabot-preview[bot] opened #4051
  • 06:51

    dependabot-preview[bot] on nuget

    Bump ApprovalTests from 3.0.10 … (compare)

  • 06:51

    dependabot-preview[bot] on nuget

    (compare)

  • 06:51
    dependabot-preview[bot] closed #4040
  • 06:51
    dependabot-preview[bot] commented #4040
  • 06:50
    dependabot-preview[bot] labeled #4050
  • 06:50
    dependabot-preview[bot] opened #4050
  • 06:50

    dependabot-preview[bot] on nuget

    Bump ApprovalUtilities from 3.0… (compare)

  • 06:50

    dependabot-preview[bot] on nuget

    (compare)

  • 06:50
    dependabot-preview[bot] closed #3991
  • 06:50
    dependabot-preview[bot] commented #3991
  • 06:50
    dependabot-preview[bot] labeled #4049
  • 06:50

    dependabot-preview[bot] on nuget

    Bump Microsoft.Extensions.Depen… (compare)

  • 06:50
    dependabot-preview[bot] opened #4049
  • Nov 18 22:20
    IgorFedchenko synchronize #4047
  • Nov 18 22:19
    IgorFedchenko synchronize #4032
wdspider
@wdspider
and if you are also using the Clustering stuff @ZoolWay created some graceful shutdown samples here: https://github.com/ZoolWay/akka-net-cluster-graceful-shutdown-samples
Marc Piechura
@marcpiechura
@fouimette @wdspider Terminate does the same as Shutdown and then returns WhenTerminated internally so you can replace these two calls to one and directly call .Wait on the Termiante call
wdspider
@wdspider
ah, thanks for clarifying.
fouimette
@fouimette
thank you
Marc Piechura
@marcpiechura
WhenTermianted can be used if you need to wait anywhere else in then code for the termination
np
fouimette
@fouimette
How can I clear out the dead letter that have accumulated in my test demo?
Aaron Stannard
@Aaronontheweb
@smitcham yep, you should be able to use a PersistentFSM with Cluster Sharding
don't know of an example
but it shouldn't be any different than any other persistent actor in terms of its behavior or setup
@fouimette dead letters are ephemeral - they're automatically logged and forgotten about unless you intercept them yourself
if you want to turn off deadletter logging there's an option for that in HOCON
Steven Mitcham
@smitcham
@Aaronontheweb thanks
I've got a PR in the Akka.DI.Unity project that updates to Unity 4, I wasn't sure whether there should be a totally different package for that since Unity >= 4 is not backwards compatible with 3.5. I've created a local package in our companies nuget feed, but it would be nice to get the full package up there.
Aaron Stannard
@Aaronontheweb
IMHO - best thing to do is to submit a pull request and see if anyone comments on it saying "OMG NO THIS WILL BE {x}"
I think it should be fine to upgrade it personally, but yeah
it's the responsibility of the people using it, at the end of the day
Steven Mitcham
@smitcham
The PR is already up if anyone wants to approve it.
Aaron Stannard
@Aaronontheweb
to speak up / take ownership of an OSS thing they care about
I'll go take a look now
fouimette
@fouimette
@Aaronontheweb Thanks!
Aaron Stannard
@Aaronontheweb
@smitcham FYI
In order to do a release, we need to do the following:
  • Update RELEASE_NOTES.md with a new version bump. Follow the convention there.
  • Submit a PR to the master branch once all of the changes have been brought in.
would you consider sending in another PR to do that?
Steven Mitcham
@smitcham
sure.
Aaron Stannard
@Aaronontheweb
and maybe upgrade to Akka.NET 1.1?
thanks, that'd be a big help
Steven Mitcham
@smitcham
also sure. I put that in a while back.
Aaron Stannard
@Aaronontheweb
I meant upgrade the package :p
so we can release it with updated dependencies
Steven Mitcham
@smitcham
yep
Aaron Stannard
@Aaronontheweb
@corneliutusnea heh, I'll give that a shot
going to be starting on that project soon-ish
Aaron Stannard
@Aaronontheweb
@smitcham doh, found a bug in the Akka.DI.TestKit because of that: akkadotnet/Akka.DI.Unity#4
already have a fix up for it: akkadotnet/akka.net#2189
fouimette
@fouimette
Is there a list of Hocon configuration options? I am looking for that dead letter logging option. Even better, where in the source can i find this option?
Steven Mitcham
@smitcham
@Aaronontheweb Here's the updated pull request. Let me know if it needs anything else akkadotnet/Akka.DI.Unity#5
Aaron Stannard
@Aaronontheweb
@fouimette the Config namespaces for each module have reference files built into them
check out the source
Arsene T. Gandote
@Tochemey
Hello how do I use EventFilter to test dead letters?
Arsene T. Gandote
@Tochemey
Hello How can I test the Event Bus pub/sub feature?
Bartosz Sypytkowski
@Horusiath
@Tochemey you can subscribe test actor or probe to event bus and verify it after publishing an event
Arsene T. Gandote
@Tochemey

@Horusiath I am doing some test of an Actor that supposes to write into file upon receiving every event. The actor subscribes to the type of event to receive. However when I published N number of events to the event bus the actor only act on the first event by writing it into the file. The others are kind of ignored. This is the test code

            ActorSystemRefs.ActorSystem = Sys;
            var actorSystem = ActorSystemRefs.ActorSystem;

            var loggingActor =
                actorSystem.ActorOf(Props.Create(() => new FileLoggerActor()));
            actorSystem.EventStream.Subscribe(loggingActor, typeof (AuditLog));
            actorSystem.EventStream.Subscribe(TestActor, typeof(Acknowleged));

            Within(TimeSpan.FromSeconds(timeout),
                () =>
                {
                    actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit1", "mobile"));
                    actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit2", "mobile"));
                    actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit3", "mobile"));
                    var result = ExpectMsgAllOf<Acknowleged>();

                    Assert.NotNull(result);
                });

and this is the Actor:

    public class FileLoggerActor : ReceiveActor
    {
        private static string _filePath;


        public FileLoggerActor()
        {
            Ready();
        }

        public override void AroundPreStart()
        {
            ReadConfiguration();
        }

        public sealed override void Ready()
        {
            Receive<AuditLog>(log =>
            {
                WriteToFile(log);
                // This code is for testing purpose
                ActorSystemRefs.PushEvent(new Acknowleged(log));
            });
        }

        private static void ReadConfiguration()
        {
            _filePath = ConfigurationManager.AppSettings["FileLogger.FilePath"];
            if (_filePath == null)
            {
                throw new ConfigurationErrorsException(
                    "Configuration appSetting FileLogger.FilePath not" +
                    "found for FileLogger actor.");
            }

            // If audit trail file path is a relative file path, 
            // convert it to an absolute path.
            _filePath = _filePath.Replace("~", AppDomain.CurrentDomain.BaseDirectory);
        }

        private static void WriteToFile(AuditLog log)
        {
            var jsonString = JsonConvert.SerializeObject(log, Formatting.None);
            File.AppendAllText(_filePath, jsonString + Environment.NewLine);
        }
    }
Arjen Smits
@Danthar
@Tochemey what if you pass the TestProbe as an dependency in your FileLoggerActor constructor, and use that reference? Instead of your 'ActorSystemRefs.PushEvent'
voltcode
@voltcode
Fxfsl
voltcode
@voltcode
Oops mobile, soz
Bartosz Sypytkowski
@Horusiath
@Tochemey what about this?:
actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit1", "mobile"));
ExpectMsg<Acknowleged>(x=> x.Property == "debit1");
actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit2", "mobile"));
ExpectMsg<Acknowleged>(x=> x.Property == "debit2");
actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit3", "mobile"));
ExpectMsg<Acknowleged>(x=> x.Property == "debit3");
or even:
actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit1", "mobile"));
actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit2", "mobile"));
actorSystem.EventStream.Publish(new AuditLog(GuidFactory.Create().ToString(), DateTime.UtcNow, "me", "0000", "debit3", "mobile"));
ExpectMsg<Acknowleged>(x=> x.Property == "debit1");
ExpectMsg<Acknowleged>(x=> x.Property == "debit2");
ExpectMsg<Acknowleged>(x=> x.Property == "debit3");
Garrard Kitchen
@garrardkitchen
Hi @Aaronontheweb, I took a punt at upgrading projects to 1.1.1 but experiencing same error with mono. Works fine on windows but not on the mac and here comes a bigger BUT….but, I’ve just realised I'm not actually comparing apples with apples here and I’m sure this will be relevant!…In win env I’m using .net but it’s only the mac I’m using mono.
Maxim Cherednik
@maxcherednik
Hi @Aaronontheweb, while Akka.Cluster was in beta the process of graceful node shutdown was a bit verbose and there were some error messages with socket exceptions and so on. That time you were saying that you guys will handle this and remove unnecessary exception logging. So at the moment I am trying the same thing - graceful node shutdown and I see some exceptions with error level ERROR - is this ok or it wasn't fixed? Even though cluster works fine. It's just those messages which makes me worried.