Change-Id: I5b9a2ec26b1b6001423f2cf5cf57285ce6c7e340
Signed-off-by: Tomas Cere <tcere@cisco.com>
try {
tx.submit().checkedGet(125, TimeUnit.SECONDS);
try {
tx.submit().checkedGet(125, TimeUnit.SECONDS);
- } catch (final TransactionCommitFailedException | TimeoutException e) {
+ } catch (final Exception e) {
LOG.warn("Unable to fill the initial item list.", e);
settableFuture.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", e).build());
LOG.warn("Unable to fill the initial item list.", e);
settableFuture.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", e).build());
.withResult(output).build());
executor.shutdown();
.withResult(output).build());
executor.shutdown();
- } catch (InterruptedException | ExecutionException | TimeoutException exception) {
+ } catch (Exception exception) {
LOG.error("Write transactions failed.", exception);
completionFuture.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", exception).build());
LOG.error("Write transactions failed.", exception);
completionFuture.set(RpcResultBuilder.<ProduceTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", exception).build());
try {
tx.submit().checkedGet(125, TimeUnit.SECONDS);
try {
tx.submit().checkedGet(125, TimeUnit.SECONDS);
- } catch (final TransactionCommitFailedException | TimeoutException e) {
+ } catch (final Exception e) {
LOG.warn("Unable to ensure IdInts list for id: {} exists.", id, e);
settableFuture.set(RpcResultBuilder.<WriteTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", e).build());
LOG.warn("Unable to ensure IdInts list for id: {} exists.", id, e);
settableFuture.set(RpcResultBuilder.<WriteTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", e).build());
try {
tx.submit().checkedGet(125, TimeUnit.SECONDS);
try {
tx.submit().checkedGet(125, TimeUnit.SECONDS);
- } catch (final TransactionCommitFailedException | TimeoutException e) {
+ } catch (final Exception e) {
LOG.warn("Unable to fill the initial item list.", e);
settableFuture.set(RpcResultBuilder.<WriteTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", e).build());
LOG.warn("Unable to fill the initial item list.", e);
settableFuture.set(RpcResultBuilder.<WriteTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", e).build());
.withResult(output).build());
executor.shutdown();
.withResult(output).build());
executor.shutdown();
- } catch (InterruptedException | ExecutionException | TimeoutException exception) {
+ } catch (Exception exception) {
LOG.error("Write transactions failed.", exception);
completionFuture.set(RpcResultBuilder.<WriteTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", exception).build());
LOG.error("Write transactions failed.", exception);
completionFuture.set(RpcResultBuilder.<WriteTransactionsOutput>failed()
.withError(RpcError.ErrorType.APPLICATION, "Unexpected-exception", exception).build());