| | |
| | | */ |
| | | private ReplicationCliReturnCode enableReplication(EnableReplicationUserData uData) |
| | | { |
| | | ConnectionWrapper conn1 = null; |
| | | ConnectionWrapper conn2 = null; |
| | | try |
| | | println(); |
| | | print(formatter.getFormattedWithPoints(INFO_REPLICATION_CONNECTING.get())); |
| | | |
| | | List<LocalizableMessage> errorMessages = new LinkedList<>(); |
| | | try (ConnectionWrapper conn1 = createAdministrativeConnection(uData.getServer1(), errorMessages); |
| | | ConnectionWrapper conn2 = createAdministrativeConnection(uData.getServer2(), errorMessages)) |
| | | { |
| | | println(); |
| | | print(formatter.getFormattedWithPoints(INFO_REPLICATION_CONNECTING.get())); |
| | | |
| | | List<LocalizableMessage> errorMessages = new LinkedList<>(); |
| | | conn1 = createAdministrativeConnection(uData.getServer1(), errorMessages); |
| | | conn2 = createAdministrativeConnection(uData.getServer2(), errorMessages); |
| | | |
| | | if (!errorMessages.isEmpty()) |
| | | { |
| | | errPrintLn(errorMessages); |
| | |
| | | return rce.getErrorCode(); |
| | | } |
| | | } |
| | | finally |
| | | { |
| | | close(conn1, conn2); |
| | | } |
| | | } |
| | | |
| | | private void checkReplicationServerAlreadyConfigured(ConnectionWrapper conn, EnableReplicationServerData server) |
| | |
| | | */ |
| | | private ReplicationCliReturnCode initializeReplication(SourceDestinationServerUserData uData) |
| | | { |
| | | ConnectionWrapper connSource = createAdministrativeConnection(uData, uData.getSource()); |
| | | ConnectionWrapper connDestination = createAdministrativeConnection(uData, uData.getDestination()); |
| | | try |
| | | try (ConnectionWrapper connSource = createAdministrativeConnection(uData, uData.getSource()); |
| | | ConnectionWrapper connDestination = createAdministrativeConnection(uData, uData.getDestination())) |
| | | { |
| | | if (connSource == null || connDestination == null) |
| | | { |
| | |
| | | } |
| | | return returnValue; |
| | | } |
| | | finally |
| | | { |
| | | close(connDestination, connSource); |
| | | } |
| | | } |
| | | |
| | | private ConnectionWrapper createAdministrativeConnection(SourceDestinationServerUserData uData, HostPort server) |