| | |
| | | { |
| | | if (shutdown == false) |
| | | { |
| | | Message message = |
| | | NOTE_DISCONNECTED_FROM_CHANGELOG.get(replicationServer, |
| | | Short.toString(rsServerId), baseDn.toString(), |
| | | Short.toString(serverId)); |
| | | logError(message); |
| | | |
| | | debugInfo("ReplicationBroker.receive() " + baseDn + |
| | | " Exception raised: " + e.getLocalizedMessage()); |
| | | if (!session.closeInitiated()) |
| | | { |
| | | /* |
| | | * If we did not initiate the close on our side, log a message. |
| | | */ |
| | | Message message = |
| | | NOTE_DISCONNECTED_FROM_CHANGELOG.get(replicationServer, |
| | | Short.toString(rsServerId), baseDn.toString(), |
| | | Short.toString(serverId)); |
| | | logError(message); |
| | | } |
| | | this.reStart(failingSession); |
| | | } |
| | | } |
| | |
| | | |
| | | private boolean debugEnabled() |
| | | { |
| | | return true; |
| | | return false; |
| | | } |
| | | |
| | | private static final void debugInfo(String s) |