public class DefaultLastStateConnectionStateListener extends Object implements LastStateConnectionStateListener
Constructor and Description |
---|
DefaultLastStateConnectionStateListener() |
Modifier and Type | Method and Description |
---|---|
Optional<org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionState> |
getLastState()
Return the last state the listener was notified about.
|
void |
stateChanged(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework client,
org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionState newState) |
public DefaultLastStateConnectionStateListener()
public Optional<org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionState> getLastState()
LastStateConnectionStateListener
getLastState
in interface LastStateConnectionStateListener
public void stateChanged(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework client, org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionState newState)
stateChanged
in interface org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionStateListener
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.