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
Maxim Cherednik
@maxcherednik
btw do you always do this?
Arjen Smits
@Danthar
nope
Dont always need guarenteed delivery
And it depends on what your doing
Maxim Cherednik
@maxcherednik
it's kind of a boiler plate code... which you need to implement on every request response
of course if it's a UI call.... I will ask UI guys to timeout and push user to request it again
Jose Carlos Marquez
@oeaoaueaa
hi, whats the approach for a cluster of servers with a "flaky" network connection where some of the nodes are marked as Unreachable? should those nodes restart themselves? if so, how do they know?
Francis Paulin
@paulinfrancis

I've got two console apps that both connect successfully to lighthouse to join a cluster. I would like to publish messages from actors in one console app to actors in the other.

In the "from" console app

var mediator = DistributedPubSub.Get(_actorSystem).Mediator;
mediator.Tell(new ClusterClient.Publish("topic-foo", "my message"));

In an actor in the "to" console app

public RaspberryPiActor()
{
    var mediator = DistributedPubSub.Get(Context.System).Mediator;
    mediator.Tell(new Subscribe("topic-foo", Self));
    Receive<SubscribeAck>(_ => Become(Subscribed));
}

private void Subscribed()
{
    Receive<string>(m =>
    {
        Console.WriteLine(m);
    });
}

Am I doing something that is evidently wrong?

Francis Paulin
@paulinfrancis
All the messages go straight to dead letters.
Jose Carlos Marquez
@oeaoaueaa
what type is the result of: new ClusterClient.Publish("topic-foo", "my message")?
from what I understand, that is the message that is being sent
Francis Paulin
@paulinfrancis
blob
Jose Carlos Marquez
@oeaoaueaa
I think you might be receiving a message of type "Publish", try Receive<Publish>(p => ....) instead
Francis Paulin
@paulinfrancis
No luck I'm afraid, but thanks for the suggestions!
Tried ReceiveAny too, just to be on the safe side
but it never hits the method
Arjen Smits
@Danthar
@paulinfrancis you are using the wrong Publish message
you should use the Akka.Cluster.Tools.PublishSubscribe.Publish message type
Sean Farrow
@SeanFarrow
Hi, I'm in a situation where I'm converting code to use actors for fault tolerance. I have a method that returns a stream, can messages return streams, or should I convert this to a byte array?
Bartosz Sypytkowski
@Horusiath
@SeanFarrow in general messages shouldn't use any disposable resources
Sean Farrow
@SeanFarrow
Hi, thanks, I'll convert the stream to a byte array then.
Rich Cox
@conejo
I have 2 questions: 1. Does Watch work with actors in the /temp hierarchy? 2. Do messages sent to an actor in the/temp hierarchy get sent to deadletters after they are killed?
Arjen Smits
@Danthar
@conejo 1: Theoretical yes. But why? 2: yes
Rich Cox
@conejo
@Danthar I'm using .Ask in a Nancy controller, and using a timespan for a timeout. I was trying to figure out how to get notified if the .Ask temp actor was killed or a message was sent to it after it was killed
Arjen Smits
@Danthar
a temp actor that gets created because of the Ask construct lives only as long, up untill the point it timeouts, or a response message is returned
watching it is pointless
its better to let the client simply retry if it timeouts
Rich Cox
@conejo
I agree on the retry, no problem there. However the controller action is not idempotent, if the result cant get returned to the client because it timed out, it needs to be undone
I made an actor to listen to the DeadLetter event stream, and subscribed it to the stream (typeof(DeadLetter)), but it's not receiving any
So, I've come up with an alternate strategy to use .Ask without a timeout (it will wait forever), and rely on ScheduleTellOnce to send a timed out notification
Chris G. Stevens
@cgstevens
What changes should I make to fix the following issue. My cluster of 10 members run fine with no unreachable issues. When I join the Cluster from my laptop which is on a different network segment and domain I get unreachable messages. Not all the time. But enough to cause disruption where other members can't join.
Bartosz Sypytkowski
@Horusiath
@conejo what's wrong with Ask + timeout?
@cgstevens which messages? Your own or system messages (like heartbeats for example)?
Ralf
@Ralf1108
for untitesting with testkit: how can the logging actor be configured via app.config? seems to be that the test actor system doesnt't tak the akka settings from app.config
Ralf
@Ralf1108
found it, ctor of Testkit takes a config as string parameter
Aaron Stannard
@Aaronontheweb
@oeaoaueaa those nodes should recover on their own accord if the connection recovers
inside Akka.Cluster
Jose Carlos Marquez
@oeaoaueaa
thanks @Aaronontheweb , got it working now, it was that I had configured an odd combination of heartbeat-interval/gossip-interval/acceptable-heartbeat-pause
Aaron Stannard
@Aaronontheweb
ahhh got it
so the heartbeat pause was too short / the heartbeat interval was too long?
Nick Cuthbert
@ncthbrt
@Aaronontheweb I've made a PR on the Quartz Actor lib. Do you know who the maintainer is?
Aaron Stannard
@Aaronontheweb
@ncthbrt that would be @maxim-s
Nick Cuthbert
@ncthbrt
Thanks. Link to issue w/ PR for convenience: akkadotnet/Akka.Quartz.Actor#29
Aaron Stannard
@Aaronontheweb
I left a comment for you on there
to do a new NuGet release, need to edit the RELEASE_NOTES.md file
(for bumping the version number and adding some release notes)
Nick Cuthbert
@ncthbrt
Cool bumped
Aaron Stannard
@Aaronontheweb
cool, @maxim-s should weigh in later tonight when it's morning his time
(timezones are weird, man)
Nick Cuthbert
@ncthbrt
+1