public static class LeaderRetrievalUtils.LeaderGatewayListener extends Object implements LeaderRetrievalListener
LeaderRetrievalListener
.Constructor and Description |
---|
LeaderGatewayListener(akka.actor.ActorSystem actorSystem,
scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<ActorGateway> |
getActorGatewayFuture() |
void |
handleError(Exception exception)
This method is called by the
LeaderRetrievalService in case of an exception. |
void |
notifyLeaderAddress(String leaderAddress,
UUID leaderSessionID)
This method is called by the
LeaderRetrievalService when a new leader is elected. |
public LeaderGatewayListener(akka.actor.ActorSystem actorSystem, scala.concurrent.duration.FiniteDuration timeout)
public void notifyLeaderAddress(String leaderAddress, UUID leaderSessionID)
LeaderRetrievalListener
LeaderRetrievalService
when a new leader is elected.notifyLeaderAddress
in interface LeaderRetrievalListener
leaderAddress
- The address of the new leaderleaderSessionID
- The new leader session IDpublic void handleError(Exception exception)
LeaderRetrievalListener
LeaderRetrievalService
in case of an exception. This
assures that the LeaderRetrievalListener
is aware of any problems occurring in the
LeaderRetrievalService
thread.handleError
in interface LeaderRetrievalListener
public scala.concurrent.Future<ActorGateway> getActorGatewayFuture()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.