CODEWITHSUNDEEP
scalaakkaakka-cluster
Chris
Chris

Reputation: 1094

Akka cluster detecting Quarantined state

How can I detect Quarantined state from within the system being quarantined~?

I'm seeing this log below:

[warn] Remoting - Tried to associate with unreachable remote address [akka.tcp://[email protected]:6000]. Address is now gated for 5000 ms, all messages to this address will be delivered to dead letters. Reason: The remote system has quarantined this system. No further associations to the remote system are possible until this system is restarted.

but I'm not sure how I can react to this from code.

I found this thread: Recovering from the Quarantined state, suggesting to listen for the QuarantinedEvent but that is not dispatched on the system being quarantined.

And I actually listened for all RemotingLifecycleEvents and found this:

AssociationError [akka.tcp://[email protected]:2552] -> [akka.tcp://[email protected]:6000]: Error [Invalid address: akka.tcp://[email protected]:6000] [akka.remote.InvalidAssociation: Invalid address: akka.tcp://[email protected]:6000 Caused by: akka.remote.transport.Transport$InvalidAssociationException: The remote system has quarantined this system. No further associations to the remote system are possible until this system is restarted.]

but that is just an AssociationError which will be dispatched for many other reasons as well, do I have to search for the actual text "The remote system has quarantined this system." within the error to be sure??

Upvotes: 5

Views: 2796

Answers (2)

Ivan Stanislavciuc
Ivan Stanislavciuc

Reputation: 7275

Following William Carter comment:

Akka provides appropriate event that does not require check of the message content. 

class MyActor extends Actor with ActorLogging {

  override def preStart(): Unit = {
    super.preStart()
    context.system.eventStream.subscribe(context.self, classOf[ThisActorSystemQuarantinedEvent])
  }

  override def receive: Receive = {
    case ev: ThisActorSystemQuarantinedEvent => log.warning(s"I was quarantined by ${ev.remoteAddress}")
  }
}

Upvotes: 3

Ivan Stanislavciuc
Ivan Stanislavciuc

Reputation: 7275

Yes, what you suggested works and can be done as follows

Subscribe an actor to akka.remote.AssociationErrorEvent 

override def preStart(): Unit = {
  context.system.eventStream.subscribe(self, classOf[akka.remote.AssociationErrorEvent])
}

and then do following in the receive method

override def receive: Receive = {
  case e:AssociationErrorEvent =>
    log.info(s"AssociationErrorEvent: $e")
    if (e.cause.getCause.getMessage.contains("quarantined this system")) {
      log.warning(s"We got quarantined")
    }
}

Upvotes: 7

Related Questions