Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 07:27
    dependabot-preview[bot] labeled #3999
  • 07:27

    dependabot-preview[bot] on nuget

    Bump FluentAssertions from 4.14… (compare)

  • 07:27
    dependabot-preview[bot] opened #3999
  • Oct 20 17:25
    valdisz synchronize #3889
  • Oct 20 17:17
    valdisz synchronize #3889
  • Oct 20 15:44
    valdisz synchronize #3889
  • Oct 20 09:22
    ismaelhamed commented #3863
  • Oct 19 23:39
    valdisz synchronize #3889
  • Oct 19 23:08
    edvinasz commented #2947
  • Oct 19 13:36
    Aaronontheweb commented #3973
  • Oct 19 13:34
    dependabot-preview[bot] synchronize #3995
  • Oct 19 13:34

    dependabot-preview[bot] on nuget

    Bump BenchmarkDotNet from 0.10.… (compare)

  • Oct 19 13:34
    dependabot-preview[bot] edited #3995
  • Oct 19 13:34
    dependabot-preview[bot] synchronize #3993
  • Oct 19 13:34

    dependabot-preview[bot] on nuget

    Bump Google.Protobuf from 3.9.1… (compare)

  • Oct 19 13:34
    dependabot-preview[bot] synchronize #3991
  • Oct 19 13:34

    dependabot-preview[bot] on nuget

    Bump Microsoft.Extensions.Depen… (compare)

  • Oct 19 13:34
    dependabot-preview[bot] synchronize #3989
  • Oct 19 13:34

    dependabot-preview[bot] on nuget

    Bump ApiApprover from 3.0.1 to … (compare)

  • Oct 19 13:34
    dependabot-preview[bot] synchronize #3992
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
You can also look at using deathwatches to detect when other nodes fail
Sebastien Bacquet
@sbacquet
what is the seed node in your mini-cluster ?
Joshua Garnett
@joshgarnett
other actors I should say
Bjørn Erik Haug
@behaug
@sbacquet The seed node is the windows service
for the service it is itself
Sebastien Bacquet
@sbacquet
Lighthouse ?
Joshua Garnett
@joshgarnett
You can watch for cluster events too, when a node goes up and down
Sebastien Bacquet
@sbacquet
ok the service itself
I think you have to install a dedicated seed node
Bjørn Erik Haug
@behaug
ok cluster events sounds interesting as a possible workaround. Do you have a doc link for this?
Sebastien Bacquet
@sbacquet
that never crashes
that keep the pub/sub info (suscribers) alive
Bjørn Erik Haug
@behaug
oh, something that never crashes is hard to guarantee