Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 18:20
    Aaronontheweb commented #6133
  • 17:28
    Aaronontheweb commented #6133
  • 17:18
    Aaronontheweb commented #6133
  • 17:18
    Aaronontheweb milestoned #6133
  • 17:18
    Aaronontheweb commented #6132
  • 17:17
    Aaronontheweb commented #6133
  • 17:16
    Aaronontheweb labeled #6133
  • 17:16
    Aaronontheweb opened #6133
  • 17:16
    Aaronontheweb labeled #6133
  • 16:35
    Aaronontheweb assigned #6125
  • 16:35
    Aaronontheweb milestoned #6125
  • 16:35
    Aaronontheweb labeled #6125
  • 16:35
    Aaronontheweb labeled #6125
  • 16:35
    Aaronontheweb milestoned #6131
  • 16:35
    Aaronontheweb labeled #6131
  • 16:34
    Aaronontheweb commented #6131
  • 16:34
    Aaronontheweb commented #6131
  • 16:31
    Aaronontheweb commented #6132
  • 16:31
    Aaronontheweb milestoned #6132
  • 16:31
    Aaronontheweb labeled #6132
Kris Schepers
@schepersk
@Horusiath So, does this also mean that you can restrict the type of a shard to a node role? Lets say you have a shard region for AR1 running on role ABC and you want to start a shard for AR2 on a completely different node with role XYZ..
Bartosz Sypytkowski
@Horusiath
each node can have multiple roles
you can have role like 'sharding-enabled' and simply refer to it from sharding settings
Kris Schepers
@schepersk
okay, but what about service1 in the cluster with 2 instances (nodes), hosting shards for its entities. Then service2 is ready to join the cluster with some instances (nodes). Each of these services have their own cluster sharding configuration. So my guess is that it should be possible to keep the entities from migrating to nodes where they don't "belong" ?
Bartosz Sypytkowski
@Horusiath
you can do the same again with roles
Kamil Wojciechowski
@aph5nt
hummm... one thing is wondering me... will akknet run on .net core now ?
Kris Schepers
@schepersk
@Horusiath I'm seeing these log entries.. Any thoughts?
Akka.Actor.LocalActorRef: Message WriteMessagesSuccessful from akka://bm2cluster/system/akka.persistence.journal.sql-server to akka://bm2cluster/user/sharding/LoonbonVerwerking/2/7afca3c0-e26c-4a97-89a5-4dd9883533b6 was not delivered. 8 dead letters encountered.
Akka.Actor.LocalActorRef: Message WriteMessageSuccess from akka://bm2cluster/temp/mb to akka://bm2cluster/user/sharding/LoonbonVerwerking/2/7afca3c0-e26c-4a97-89a5-4dd9883533b6 was not delivered. 9 dead letters encountered.
Maybe because they already got passivated before persistence could provide feedback?
Vagif Abilov
@object
SQL Server persistence plugin works in 1.0.7 if I build it from sources but when I use a version from NuGet I get TypeLoadException
{"Method 'DeleteBatchMessages' in type 'Akka.Persistence.SqlServer.Journal.SqlServerJournalQueryBuilder' from assembly 'Akka.Persistence.SqlServer, Version=1.0.6.3, Culture=neutral, PublicKeyToken=null' does not have an implementation.":"Akka.Persistence.SqlServer.Journal.SqlServerJournalQueryBuilder"}
Marc Piechura
@marcpiechura
@object you need Akka.Persistence.SqlServer, Version=1.0.7 for akka 1.0.7
Vagif Abilov
@object
@Silv3rcircl3 but where can I get it from? It's not on NuGet.
I see that none of NuGet packages for the actual persistence plugins has been updated to 1.0.7 on NuGEt.
Thomas Lazar
@thomaslazar
so i have a question. i have an actor that gets a message from a remote client. in this message is information about a class this actor should retrieve from the container and a method and a bunch of params that the actor should call as well as the return type. so i have this actor that retrieves the object form the container, checks if there's a method on that class that fits the description of the message and then tries to call it with Invoke(). so far so good. it is all working so far. i put this Invoke() call inside a try catch block because i basically want to tell the sender if something happened to while calling the method and basically return the thrown exception as a message back to sender. but when the invoked method itself throws a TargetInvocationException because of reasons it seems the actor just dies. and i get some disassociation messages in the log and stuff like that. it's like the try catch block inside the receive method is just not working. any hints?
Marc Piechura
@marcpiechura
@object indeed, then you can't use akka 1.0.7 with persistence until the plugin get's updated
@object there is a PR akkadotnet/Akka.Persistence.SqlServer#24 that updates the plugin, so you need to wait until this was merged and released
Vagif Abilov
@object
Oh I see, thanks.
ilhadad
@ilhadad
What does this mean when building Akka.net
---------------------------------------------------------------------
  1) Building C:\CF\SourceCode\akka.net\src\Akka.sln failed with exitcode 1.
  2) MSB4126: C:\CF\SourceCode\akka.net\src\Akka.sln.metaproj(0,0): The specified solution configuration "Release|MCD" is invalid. Please specify a valid solution configuration using the Configuration and Platform properties (e.g. MSBuild.exe Solution.sln /p:Configuration=Debug /p:Platform="Any CPU") or leave those properties blank to use the default solution configuration.
---------------------------------------------------------------------
How do I rectify this problem? I am building from the command line using build build
Aaron Stannard
@Aaronontheweb
the .SLN does not have a build configuration that looks like that
@schepersk you need to exclude Lighthouse from your shard regions in your configuration
it will never work
under any circumstances
because it doesn't run Akka.Cluster.Sharding or Akka.Persistence or Akka.Cluster.Tools
use the roles setting
Chris G. Stevens
@cgstevens
Are there any examples using Akka.Cluster.Tools ... I want to take my Cluster Monitor WinForms and be able to get the cluster info without having to part of the cluster.
Chris Constantin
@cconstantin
@andreabalducci what @Horusiath said :)
Aaron Stannard
@Aaronontheweb
@cgstevens there are some in the main repo
Bartosz Sypytkowski
@Horusiath
@schepersk your log suggest that your actor may be dead after persisting message inside the journal
ilhadad
@ilhadad

I am trying to run the cluster sharding example. Since I cannot compile the akka project I pulled the ClusterSharding.Node out into a clean solution. Installed all the references via Nuget. I am getting an error in the following line:

        public override string PersistenceId { get; } = Context.Parent.Path.Name + "/" + Context.Self.Path.Name;

The error is...

Akka.Persistence.UntypedPersistentActor.Context' is a 'property' but is used like a 'type'

What's missing?

Andreas Dirnberger
@Zetanova
Is the Ask valid in this sence or should i try to remove it in general?
var creditor = Context.ActorOf(PaymentCreditor.GetProps());
            service.Ask(AccountCommands.GetIdentity(state.AccountId))
                .PipeTo(creditor, success: m => PaymentProcessCommands.Credit(Id, m, state.Description, state.Amount));
Bartosz Sypytkowski
@Horusiath
@Zetanova you could use service.Tell(AccountCommands.GetIdentity(state.AccountId), creditor) and set message mapping on either sender or receiver side to have a valid value
this will set creditor as message sender
Andreas Dirnberger
@Zetanova
i am resolving one field of the command
of course the PaymentCreditor could do it to, but i would need to reduce the PaymentProcessCommands.Credit to AccountId-GUID
If i am sending the accountIdentity to the creditor before the credit command to set up the state, i would need to remove the account field of the credit command
Andreas Dirnberger
@Zetanova
Soem like a jumbo command generator pattern or actor initialize message pattern is missing me
Hyungho Ko
@hhko
Hi. @Horusiath Akka.NET 1.0.7 supports SupervisorStrategyConfigurator class for user guardian.
this is sample hocon.
      akka {
        actor {
          guardian-supervisor-strategy = "UserSupervisorExample.UserSupervisorStrategy"
        }
      }

namespace UserSupervisorExample
{
public class UserSupervisorStrategy : SupervisorStrategyConfigurator
{
public UserSupervisorStrategy()
{

    }

    public override SupervisorStrategy Create()
    {
        return new OneForOneStrategy((excep) =>
            {
                int x = 3;
                x = 6;

                return Directive.Restart;
            });
    }
}

}

however, Exception occurs in ActorSystem
Hyungho Ko
@hhko
blob
Marc Piechura
@marcpiechura
@hhko you need to provide the full qualified name, see the specs for an example
Hyungho Ko
@hhko
@Silv3rcircl3 thank you... I solve it. below
akka {
actor {
guardian-supervisor-strategy = "HelloWorldUserSupervisor.UserSupervisorStrategy, HelloWorldUserSupervisor"
}
}
i forget dll name. ^^;;
Andrea Balducci
@andreabalducci
@cconstantin @Horusiath if so I think JournalDbEngine (reference implementation) is buggy. should stop on first failure, now has a ContinueWhenAll so the stream can be corrupted rather than incomplete
Bartosz Sypytkowski
@Horusiath
@andreabalducci can you set an issue for that with some description?
Andrea Balducci
@andreabalducci
@Horusiath #1883 , I'm new to akka.net but have some background on EventSourcing / stream persistence. thank you for you help
Thomas Lazar
@thomaslazar
anyone got anything on my problem? i have a remote actor that i send a message to via a client. and as soon as that remote actor does anything that generates an exception that gets caught and handled in the remote actor the connection gets disassociated and the thing basically dies. what am i doing wrong here?