| | |
| | | HashMap<String, ServerState> rsStates = new HashMap<String, ServerState>(); |
| | | |
| | | // Stop any existing heartbeat monitor from a previous session. |
| | | if (heartbeatMonitor != null) |
| | | { |
| | | heartbeatMonitor.shutdown(); |
| | | heartbeatMonitor = null; |
| | | } |
| | | stopHeartBeat(); |
| | | |
| | | synchronized (connectPhaseLock) |
| | | { |
| | |
| | | } |
| | | |
| | | /** |
| | | * Stop the heartbeat monitor thread. |
| | | */ |
| | | void stopHeartBeat() |
| | | { |
| | | if (heartbeatMonitor != null) |
| | | { |
| | | heartbeatMonitor.shutdown(); |
| | | heartbeatMonitor = null; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * restart the ReplicationBroker. |
| | | */ |
| | | public void reStart() |
| | |
| | | replicationServer = "stopped"; |
| | | shutdown = true; |
| | | connected = false; |
| | | if (heartbeatMonitor != null) |
| | | { |
| | | heartbeatMonitor.shutdown(); |
| | | } |
| | | try |
| | | { |
| | | if (debugEnabled()) |