Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • Nov 17 23:00
    djm132 opened #4045
  • Nov 17 21:35
    ColinPM opened #4044
  • Nov 17 16:05
    Zetanova commented #4032
  • Nov 16 16:14
    IgorFedchenko commented #4032
  • Nov 16 13:19
    ismaelhamed synchronize #4042
  • Nov 16 13:17
    ismaelhamed commented #3863
  • Nov 16 11:47
    IgorFedchenko synchronize #4032
  • Nov 16 11:47
    IgorFedchenko commented #4032
  • Nov 16 11:21
    ismaelhamed synchronize #3863
  • Nov 16 11:17
    ismaelhamed edited #3863
  • Nov 16 11:17
    ismaelhamed synchronize #4042
  • Nov 16 09:58
    IgorFedchenko synchronize #4032
  • Nov 16 09:49
    IgorFedchenko synchronize #4032
  • Nov 16 09:45
    IgorFedchenko commented #4032
  • Nov 16 09:17
    ismaelhamed opened #4043
  • Nov 16 09:03
    ismaelhamed opened #4042
  • Nov 16 09:03
    IgorFedchenko commented #4032
  • Nov 16 08:59
    IgorFedchenko synchronize #4032
  • Nov 16 08:57
    IgorFedchenko synchronize #4032
  • Nov 15 22:35
    Aaronontheweb commented #4032
Onur Gumus
@OnurGumus
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
Using remote exposes your entire network.
Arjen Smits
@Danthar
@boekabart added some remarks. I suppose you need to add some more examples to illustrate the need for this change ;)
Arsene T. Gandote
@Tochemey
@jeff-pang All I can tell you is that I have used it with Xamarin and it works smoothly. Instead of Http I use akka remote to communicate between the mobile app and the backend service. So the mobile app had a mini akka system.
There is no harm in trying
Arsene T. Gandote
@Tochemey
Hello geeks how different is the Polly circuit breaker from the Akka.NEt one because I am not seeing any where how to handle the exception.
Bart de Boer
@boekabart

@Danthar

@boekabart added some remarks. I suppose you need to add some more examples to illustrate the need for this change ;)

I've elaborated a bit in the ticket, and will try to add actual code examples. But since the problem is mainly caused by the need to be able to 'compose' actors in a generic way, it's not so trivial to explain in a simple example.

Arjen Smits
@Danthar
Ok, So if i understand correctly. Sometimes you want the original sender, so you use (s) => new msg(s) as the func
and sometimes you want to use a different sender, so you use (s) => new msg(d) as the func
and the reason you want this message factory func, because it would enable you to NOT use all kinds of nasty fallback code in either the sending or receiving code
/cc @boekabart
Greatsamps
@Greatsamps
Hey Guys, i have a question about performing an orderly shutdown. I am aware that it is benefitial for an actor node to be taken offline gracefully so that the cluster is aware that it is gone for a specific reason and has not just simply failed. When running in a micro-services situation where nodes will often be running via docker, is there any way that a graceful shutdown can be performed, or do you just have to deal with it being dirty as docker stops the container?
Bart de Boer
@boekabart
@Danthar well in fact the only reason we need the Func<IActorRef,object> is the use case actor.Ask<MyResponse>( (ref) => new SendAnswerTo(ref));- your first example. This code resides either in a Unit Test (although usually we are OK with using TestActor as recipient), or in production code in an Api Controller ("HTTP to Akka converter"). The second case resides in other actors, not using ask but just .Tell( new SendAnswerTo( thisActorIVaguelyKnow )) .
Kamil Wojciechowski
@aph5
Good evening, i have one question about the actor communication in a cluster. lets say that we have 2 actors, each configured to be in a different cluster role and deployed to 2 different machines. If actor A wants to send a message to actor B, then could it be done as a normal Tell? (those actors are in the same system)
or should I use Cluster Client OR distributed pub/sub ?
Aaron Stannard
@Aaronontheweb
yep, can be done as a normal tell
ClusterClient is really for instances where something "outside" of the cluster needs to be able to connect into it
DistributedPubSub is for doing topic brokering inside the cluster
Kamil Wojciechowski
@aph5
ok, thanks !
Arsene T. Gandote
@Tochemey
Hello I would like to know whether there is a very simple tutorial on the Akka Cluster. I have gone through the WebCrawler and honestly speaking I get confused even though I have been using Akka net. If I can get a simple tutorial of three nodes on cluster I believe it will help.
Aaron Stannard
@Aaronontheweb
have you checked out docs on the website and some of our youtube videos?
Arsene T. Gandote
@Tochemey
@Aaronontheweb I have gone through the doc site and I really love it. However how to start is my issue. :worried:
I'd recommend playing around with that
Arsene T. Gandote
@Tochemey
Ok
Aaron Stannard
@Aaronontheweb
starts a basic 3 node cluster all inside a single process