Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Nov 21 23:45
    nagytech commented #4054
  • Nov 21 23:40
    MaximG1234 commented #4054
  • Nov 21 23:37
    MaximG1234 commented #4054
  • Nov 21 23:37
    MaximG1234 commented #4054
  • Nov 21 23:36
    nagytech commented #4054
  • Nov 21 23:36
    nagytech commented #4054
  • Nov 21 23:36
    MaximG1234 commented #4054
  • Nov 21 23:12
    MaximG1234 commented #4054
  • Nov 21 23:12
    MaximG1234 commented #4054
  • Nov 21 23:11
    MaximG1234 commented #4054
  • Nov 21 21:54
    nagytech commented #4054
  • Nov 21 21:44
    Aaronontheweb commented #4054
  • Nov 21 21:44
    Aaronontheweb commented #4054
  • Nov 21 21:33
    MaximG1234 commented #4054
  • Nov 21 21:31
    Aaronontheweb commented #4054
  • Nov 21 21:31
    MaximG1234 commented #4054
  • Nov 21 21:31
    MaximG1234 commented #4054
  • Nov 21 20:04
    Aaronontheweb synchronize #4022
  • Nov 21 20:03

    Aaronontheweb on dev

    NRE fix (#4056) (compare)

  • Nov 21 20:03
    Aaronontheweb closed #4056
Aaron Stannard
@Aaronontheweb
and the usage of a gossip protocol was necessary for getting all of the topology information about which replicas were / were not available
"tunable consistency"
like, I think what was original about Dynamo wasn't any one idea
nathvi
@nathvi
Thanks!
Aaron Stannard
@Aaronontheweb
but the combination of all of them
Akka.NET's "ring-based partitioning" comes from consistent hashing routers and Cluster.Sharding's use of the same algos for shard placement
doesn't quite have the same opinionated design that Dynamo does since we're not a database - we're a multi-purpose framework
nathvi
@nathvi
Aaron Stannard
@Aaronontheweb
thanks! hope you liked it
nathvi
@nathvi
I did. Though, I'm not sure I understand this...
"I can’t understate ..." Should that be "I can't overstate"?
Aaron Stannard
@Aaronontheweb
probably
I just kind of rifle those posts out extemporaneously
nathvi
@nathvi
:)
Aaron Stannard
@Aaronontheweb
and I don't go back and revise them
which... is probably not a best practice
nathvi
@nathvi
lol,
I think open source software has had a huge part in pushing Microsoft to be more open
It's hard to compete with free
Looking to make my own company.
Onur Gumus
@OnurGumus
In a cluster, if a node is temporarily down and comes back alive after it is quarantined, it cannot rejoin to the cluster. What should I do for this case ?
Joshua Garnett
@joshgarnett
Restart the node
Onur Gumus
@OnurGumus
How can I detect that is quarantined?
Joshua Garnett
@joshgarnett
I’m pretty sure events are generated
Onur Gumus
@OnurGumus
Perhaps but can't find
hmm we have this Akka.Remote.QuarantinedEvent
@joshgarnett how do I restart a node without killing the process ?
Joshua Garnett
@joshgarnett
That’s what I mean
You have to restart the process
Of the node that was quarantined
Onur Gumus
@OnurGumus
Oh ok
Onur Gumus
@OnurGumus
@joshgarnett well you can actually just restart the system without killing the process
Joshua Garnett
@joshgarnett
Fair enough, in my experience if you were quarantined it was probably for a good reason and it’s makes sense to just do a full restart of the process.
Everyone’s use case is different though
Onur Gumus
@OnurGumus
I agree that is debatable
but it is an option.
Onur Gumus
@OnurGumus
From the following disassociation message, what can I deduce?
{"@t":"2018-03-23T11:13:46.3025809Z","@mt":"Association with remote system {0} has failed; address is now gated for {1} ms. Reason is: [{2}]","@l":"Warning","0":"akka.tcp://SmartGateSystem@localhost:9083","1":5000,"2":"Akka.Remote.EndpointDisassociatedException: Disassociated\r\n at Akka.Remote.EndpointWriter.PublishAndThrow(Exception reason, LogLevel level, Boolean needToThrow)\r\n at Akka.Remote.EndpointWriter.Unhandled(Object message)\r\n at Akka.Actor.ReceiveActor.ExecutePartialMessageHandler(Object message, PartialAction1 partialAction)\r\n at Akka.Actor.ReceiveActor.OnReceive(Object message)\r\n at Akka.Actor.UntypedActor.Receive(Object message)\r\n at Akka.Actor.ActorBase.AroundReceive(Receive receive, Object message)\r\n at Akka.Actor.ActorCell.ReceiveMessage(Object message)\r\n at Akka.Actor.ActorCell.ReceivedTerminated(Terminated t)\r\n at Akka.Actor.ActorCell.AutoReceiveMessage(Envelope envelope)\r\n at Akka.Actor.ActorCell.Invoke(Envelope envelope)\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at Akka.Actor.ActorCell.HandleFailed(Failed f)\r\n at Akka.Actor.ActorCell.SysMsgInvokeAll(EarliestFirstSystemMessageList messages, Int32 currentState)","Thread":"0014","LogSource":"[akka://SmartGateSystem/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FSmartGateSystem%40localhost%3A9083-21#899920873]","Timestamp":"2018-03-23T11:13:46.2955809Z","SourceContext":"akka://SmartGateSystem/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FSmartGateSystem%40localhost%3A9083-21","ApplicationSession":"bd4970e6-13cf-4d8b-b182-4cc438c736a4"}
`
Roman Golenok
@shersh

Hi guys, I'm running Lighthouse with configs

 remote {
            log-remote-lifecycle-events = DEBUG
            dot-netty.tcp {
              hostname = "127.0.0.1"
              port = 3333
            }
          }

But it's unreachable from non local clients.
if I change hostname to "0.0.0.0" I see errors like
dropping message for non-local recipient

So how I should change config for remote actor for using it's from outside of localhost?
AndreSteenbergen
@AndreSteenbergen
I am not that far that I can use multiple nodes with my own solution, but if I recall correct, you can also set a public host (it's actually in the lighthouse example) public-hostname = "POPULATE STATIC IP HERE"
I guess you will need to set that property as well.
nathvi
@nathvi
ello
Making a powerpoint to bring the good news of Akka to the team
nathvi
@nathvi
And within that powerpoint I'm making messaging animations
Bart de Boer
@boekabart
I've created a PR that extends Ask() with an option to use the Ask's IActorRef in constructing the sent message:
akkadotnet/akka.net#3373
Arsene T. Gandote
@Tochemey
Hello can someone shows me a complete sample of the circuit breaker implementation?
nathvi
@nathvi
humm
I'm confused on the example provided in the documentation. In the OnReceive method override, at the very end there is a statement "Self.Tell("continue");" I understand that this sends a message to the current actor, but I don't see any code that checks to see if the message object is "continue". Is this code handled by akka.net?
Jeff Pang
@jeff-pang
Hi everyone, may I know if any of you have any experience or resources on Akka Java on Android?
Can't seem to find much info on this topic. is Akka (Java) even compatible with Android?
AndreSteenbergen
@AndreSteenbergen
No experience for me, but if you are using remote, I would use some extra middle layer communicating with your clients, like RabbitMq