Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Oct 15 20:04
    IgorFedchenko synchronize #3973
  • Oct 15 20:03
    IgorFedchenko synchronize #3973
  • Oct 15 19:34
    IgorFedchenko synchronize #3973
  • Oct 15 17:53
    Aaronontheweb closed #3972
  • Oct 15 17:53
    Aaronontheweb commented #3972
  • Oct 15 17:53
    Aaronontheweb closed #3976
  • Oct 15 17:53
    Aaronontheweb commented #3976
  • Oct 15 17:40

    Aaronontheweb on dev

    cleaned up some samples to use … (compare)

  • Oct 15 17:40
    Aaronontheweb closed #3975
  • Oct 15 16:33
    IgorFedchenko synchronize #3973
  • Oct 15 16:31
    IgorFedchenko synchronize #3973
  • Oct 15 14:04
    wsvdyk opened #3976
  • Oct 14 21:02
    Aaronontheweb synchronize #3975
  • Oct 14 21:02
    Aaronontheweb opened #3975
  • Oct 14 20:11
    IgorFedchenko commented #3973
  • Oct 14 20:10
    IgorFedchenko synchronize #3973
  • Oct 14 20:06
    IgorFedchenko synchronize #3973
  • Oct 14 20:06
    IgorFedchenko synchronize #3973
  • Oct 14 19:42
    IgorFedchenko edited #3973
  • Oct 14 18:08
    Aaronontheweb commented #3937
KiransHub
@KiransHub
I was thinking to get the person working with me pair programming for about 4 months or so.
Aaron Stannard
@Aaronontheweb
that'd do it
KiransHub
@KiransHub
then after that
they need to be at least self sustaining
preferably making money
There aren't many local permanent employees I know that I'd want to hire.
Maybe I could take a look at local meetups or something
and get a feel for people's skills and expectations.
A sort of "market research"
Ondrej Pialek
@ondrejpialek

Using ddata and for some reason I cannot create a shard proxy on a node that has a different cluster role...

Error while creating actor instance of type Akka.DistributedData.Replicator with 1 args: (Akka.DistributedData.ReplicatorSettings) ---> System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. ---> System.ArgumentException: The cluster node akka.tcp://my-system@localhost:30020 does not have the role backend

Is this supposed to work? I have two nodes, one is in role api and the other in role backend. the backend node has a proper shard region and the api node tries to create a proxy, specifying the entities live on the backend node..

Ondrej Pialek
@ondrejpialek
Seems like this line: https://github.com/akkadotnet/akka.net/blob/c954b79f55be3ecb7da64a4d18bc071c18a03c64/src/contrib/cluster/Akka.DistributedData/Replicator.cs#L353 requires that the node that creates the proxy to also be in the same role of the entities it wants to communicate with. This seems to be like an explicit requirement here, the persistent approach does not enforce this, I wonder what is the reason for the check here with ddata...
Bartosz Sypytkowski
@Horusiath
@ondrejpialek have you tried to setup role via akka.cluster.sharding.distributed-data.role = backend?
Ondrej Pialek
@ondrejpialek
@Horusiath I have not after I read the following line: https://github.com/akkadotnet/akka.net/blob/c954b79f55be3ecb7da64a4d18bc071c18a03c64/src/contrib/cluster/Akka.Cluster.Sharding/ClusterShardingGuardian.cs#L262 It seems that it will always override that role if you provide a different role in the settings of your shard region / proxy.
Bartosz Sypytkowski
@Horusiath
I must check it, it may be a bug
Ondrej Pialek
@ondrejpialek
Do you want me to provide a clearer description somewhere, say a GitHub issue?
Bartosz Sypytkowski
@Horusiath
sure, it's easy to loose track of issues in gitter
github issue tracker is much better place
thanks for help :)
Ondrej Pialek
@ondrejpialek
sure, will do that then ;)
.. thank you for looking into this :)
jalchr
@jalchr
Hi @Aaronontheweb ... yes it looks similar to akkadotnet/akka.net#2529
I actually was using the recommended configuration mentioned in that issue.
The troubling issue is that everything works fine for a long period of time ... then things start to collapse.
I wonder if Akka.net startup has a retry mechanism (with a timeout) to wait for the port before throwing ...
This way ... competing for the same port (like what happens when IIS recycles an application) will work in all cases
TonyLo1
@TonyLo1
@Horusiath, hi, trying to run your akkling streams client server example. Get runtime exception from Graph.run mat. System.InvalidCastException: 'Unable to cast object of type 'Akka.NotUsed' to type 'Microsoft.FSharp.Core.Unit'.' Following the flow types I dont see why this is a problem but it is for some reason. I have tried both the nuget 0.8 version of the libs plus downloaded the source and rebuilt and still get the same problem. Any ideas?
chipdice
@chipdice

I am trying to implement a PriorityMailbox but getting the following error. My mailbox extends UnboundedPriorityMailbox and overrides PriorityGenerator. I seem to have the hocon configured properly but get the following exception. I am using akka 1.2.3. Cn anyone clarify what I am missing?

Akka.Configuration.ConfigurationException
HResult=0x80131500
Message=Configuration problem while creating [akka://PMTBetaActorSystem/user/ConnectionManager/ConsolidationController-bd1d6104-e65b-4cb6-9b0c-9060586b8575/StreamingConsolidator] with dispatcher [akka.actor.default-dispatcher] and mailbox [user-request-priority]
Source=Akka
StackTrace:
at Akka.Actor.LocalActorRefProvider.ActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor, ActorPath path, Boolean systemService, Deploy deploy, Boolean lookupDeploy, Boolean async)
at Akka.Remote.RemoteActorRefProvider.LocalActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor, ActorPath path, Boolean systemService, Deploy deploy, Boolean lookupDeploy, Boolean async)
at Akka.Remote.RemoteActorRefProvider.ActorOf(ActorSystemImpl system, Props props, IInternalActorRef supervisor, ActorPath path, Boolean systemService, Deploy deploy, Boolean lookupDeploy, Boolean async)
at Akka.Actor.ActorCell.MakeChild(Props props, String name, Boolean async, Boolean systemService)
at Akka.Actor.ActorCell.ActorOf(Props props, String name, Boolean isAsync, Boolean isSystemService)
at Akka.Actor.ActorCell.ActorOf(Props props, String name)
at PMTPositionConsolidation.Actors.Consolidation.ConsolidatorSupervisor.HandleUserViewMessage(UserViewRequest uvr) in C:_Work_WebServerDev\Firm.PMTPositionConsolidatorService\PMTPositionConsolidation\Actors\Consolidation\ConsolidatorSupervisor.cs:line 87

Inner Exception 1:
ArgumentException: produced message queue type of [Akka.Dispatch.MessageQueues.UnboundedPriorityMessageQueue] does not fulfill requirement for actor class [PMTPositionConsolidation.Actors.Consolidation.Consolidator].Must be a subclass of [Akka.Dispatch.MessageQueues.IMessageQueue]

chipdice
@chipdice
Ah, I see. My actor Implements IWithUnboundedStash so UnboundedPriorityMailbox is not the correct class to extend (I see the note on this about stashing, however the docs say that UnboundedPriorityMailbox supports stashing. Maybe not with the version I am running?)
Martin Clode
@MClode
Anyone know why running something like |> Source.batch ((int64)10) (fun x -> [x]) (fun acc x -> x::acc) |> Source.runForEach ... would result in running on a batch size of 1 all the time?
Marc Piechura
@marcpiechura
@MClode because batch only collects if your consumer is slower than your producer
Add Source.throttle before runForEach , that should backpressure and therefore force the batch to actually batch elements
Martin Clode
@MClode
Thanks @marcpiechura :)
Bartosz Sypytkowski
@Horusiath
@TonyLo1 are you talking about Akka TCP client/server streams? I've found that bug some time ago, I'll try to fix it in the latest update
TonyLo1
@TonyLo1
@Horusiath - yes the TCP client/server streams, great thanks
Aaron Stannard
@Aaronontheweb
@chipdice I thought we patched that bug around 1.2.3 or earlier
aha
I stand corrected
akkadotnet/akka.net#2649
fixed that in the 1.3.0 release
Edson Flores Palma
@Efp95
Hello, is it somehow to set a gossip-interval for Akka.DistributedData?
Bartosz Sypytkowski
@Horusiath
@Efp95 akka.cluster.distributed-data.gossip-interval = 2s (by default it's 2 sec)
Edson Flores Palma
@Efp95
Wow, didn't realize. Thanks!
Bjørn Erik Haug
@behaug
I am writing an application using a windows service acting as a single-node akka.net cluster and it is using DistributedPubSub messaging. I have a client application as a web app that joins the cluster to subscribe to messages. Is this the right approach? I see that if I restart the windows service the web app rejoins the cluster an Tell messages work again, but it is no longer receiving subscribed messages. How do I restore subscriptions in this case?
Bartosz Sypytkowski
@Horusiath
@behaug if this is your use case, do you even need akka on the first place?
Bjørn Erik Haug
@behaug
@Horusiath I use akka for the messaging part, not the clustering part. I will run single instance, but I want the message passing with pub/sub. Is there another framework I should look at?
Joshua Garnett
@joshgarnett
@behaug there was a pub/sub bug fixed in 1.3.5
That said, running distributed pub/sub for a single node does feel a little overkill
I’m assuming when the client connects, it’s re-issuing subscribes?
Bjørn Erik Haug
@behaug

Thank I will try upgrading to 1.3.5. I am at 1.3.4 now.

When the client starts it will resubscribe, but not if only the server is recycled. How can I implement that?

Joshua Garnett
@joshgarnett
The client should detect that it needed to reconnect to the server and then re-issue the subscribes. How are you communicating between the client and server?
Bjørn Erik Haug
@behaug
They join the same cluster
Joshua Garnett
@joshgarnett
Got it, give 1.3.5 a try and see if that does the trick