Examples of com.sleepycat.je.rep.StateChangeListener.stateChange()

com.sleepycat.je.rep.StateChangeListener.stateChange()

The notification method. It is initially invoked when the {@code StateChangeListener} is first associated with the {@code ReplicatedEnvironment} via the {@link ReplicatedEnvironment#setStateChangeListener(StateChangeListener)}method and subsequently each time there is a state change.

This method should do the minimal amount of work, queuing any resource intensive operations for processing by another thread before returning to the caller, so that it does not unduly delay the other housekeeping operations performed by the internal thread which invokes this method.

@param stateChangeEvent the new state change event @throws RuntimeException Any uncaught exceptions will result in theshutdown of the ReplicatedEnvironment.

            }


            StateChangeListener listener = _stateChangeListener.get();
            if (listener != null && (_state.get() == State.OPEN || _state.get() == State.RESTARTING))
            {
                listener.stateChange(stateChangeEvent);
            }


            if (_lastKnownEnvironmentState == ReplicatedEnvironment.State.MASTER && state == ReplicatedEnvironment.State.DETACHED && _state.get() == State.OPEN)
            {
                tryToRestartEnvironment(null);

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.