- try {
- LOG.info("deleting l2 gateway connection {}",l2gatewayConnection.key());
- txRunner.callWithNewWriteOnlyTransactionAndSubmit(Datastore.CONFIGURATION,
- tx -> tx.delete(connectionInstanceIdentifier)).get();
- LOG.info("recreating l2 gateway connection {}, {}",entityId, l2gatewayConnection.key());
- txRunner.callWithNewWriteOnlyTransactionAndSubmit(Datastore.CONFIGURATION,
- tx -> tx.put(connectionInstanceIdentifier, l2gatewayConnection)).get();
- } catch (InterruptedException | ExecutionException e) {
- LOG.error("Service recovery failed for l2gw connection {}", entityId);
- }
- }
+ LOG.info("deleting l2 gateway connection {}",l2gatewayConnection.key());
+ txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION,
+ tx -> tx.delete(connectionInstanceIdentifier));
+ LOG.info("recreating l2 gateway connection {}, {}",entityId, l2gatewayConnection.key());
+ txRunner.callWithNewWriteOnlyTransactionAndSubmit(CONFIGURATION,
+ tx -> tx.put(connectionInstanceIdentifier,l2gatewayConnection));