| | |
| | | private Short identifier; |
| | | private boolean connected = false; |
| | | private SynchronizationDomain domain; |
| | | private Object lock = new Object(); |
| | | private final Object lock = new Object(); |
| | | private String changelogServer = "Not connected"; |
| | | private TreeSet<FakeOperation> replayOperations; |
| | | private ProtocolSession session = null; |
| | |
| | | /** |
| | | * Restart the Changelog broker after a failure. |
| | | * |
| | | * @param failingSocket the socket which failed |
| | | * @param failingSession the socket which failed |
| | | */ |
| | | private void reStart(ProtocolSession failingSession) |
| | | { |