diff --git a/src/main/java/net/helenus/core/operation/AbstractOperation.java b/src/main/java/net/helenus/core/operation/AbstractOperation.java index aff7d77..09649dd 100644 --- a/src/main/java/net/helenus/core/operation/AbstractOperation.java +++ b/src/main/java/net/helenus/core/operation/AbstractOperation.java @@ -41,7 +41,7 @@ public abstract class AbstractOperation> ex return new PreparedOperation(prepareStatement(), this); } - public E sync() throws TimeoutException { + public E sync() {//throws TimeoutException { final Timer.Context context = requestLatency.time(); try { ResultSet resultSet = this.execute(sessionOps, null, traceContext, queryExecutionTimeout, queryTimeoutUnits, @@ -52,7 +52,7 @@ public abstract class AbstractOperation> ex } } - public E sync(UnitOfWork uow) throws TimeoutException { + public E sync(UnitOfWork uow) {//throws TimeoutException { if (uow == null) return sync(); @@ -69,11 +69,11 @@ public abstract class AbstractOperation> ex public CompletableFuture async() { return CompletableFuture.supplyAsync(() -> { - try { +// try { return sync(); - } catch (TimeoutException ex) { - throw new CompletionException(ex); - } +// } catch (TimeoutException ex) { +// throw new CompletionException(ex); +// } }); } @@ -81,11 +81,11 @@ public abstract class AbstractOperation> ex if (uow == null) return async(); return CompletableFuture.supplyAsync(() -> { - try { +// try { return sync(); - } catch (TimeoutException ex) { - throw new CompletionException(ex); - } +// } catch (TimeoutException ex) { +// throw new CompletionException(ex); +// } }); } } diff --git a/src/main/java/net/helenus/core/operation/AbstractOptionalOperation.java b/src/main/java/net/helenus/core/operation/AbstractOptionalOperation.java index 9a14a02..86e3dd8 100644 --- a/src/main/java/net/helenus/core/operation/AbstractOptionalOperation.java +++ b/src/main/java/net/helenus/core/operation/AbstractOptionalOperation.java @@ -64,7 +64,7 @@ public abstract class AbstractOptionalOperation sync() throws TimeoutException { + public Optional sync() {//throws TimeoutException { final Timer.Context context = requestLatency.time(); try { ResultSet resultSet = this.execute(sessionOps, null, traceContext, queryExecutionTimeout, queryTimeoutUnits, @@ -75,7 +75,7 @@ public abstract class AbstractOptionalOperation sync(UnitOfWork uow) throws TimeoutException { + public Optional sync(UnitOfWork uow) {//throws TimeoutException { if (uow == null) return sync(); @@ -118,11 +118,11 @@ public abstract class AbstractOptionalOperation> async() { return CompletableFuture.>supplyAsync(() -> { - try { +// try { return sync(); - } catch (TimeoutException ex) { - throw new CompletionException(ex); - } +// } catch (TimeoutException ex) { +// throw new CompletionException(ex); +// } }); } @@ -130,11 +130,11 @@ public abstract class AbstractOptionalOperation>supplyAsync(() -> { - try { +// try { return sync(); - } catch (TimeoutException ex) { - throw new CompletionException(ex); - } +// } catch (TimeoutException ex) { +// throw new CompletionException(ex); +// } }); } } diff --git a/src/main/java/net/helenus/core/operation/AbstractStreamOperation.java b/src/main/java/net/helenus/core/operation/AbstractStreamOperation.java index 0d3e1d8..a51e522 100644 --- a/src/main/java/net/helenus/core/operation/AbstractStreamOperation.java +++ b/src/main/java/net/helenus/core/operation/AbstractStreamOperation.java @@ -57,7 +57,7 @@ public abstract class AbstractStreamOperation sync() throws TimeoutException { + public Stream sync() {//throws TimeoutException { final Timer.Context context = requestLatency.time(); try { ResultSet resultSet = this.execute(sessionOps, null, traceContext, queryExecutionTimeout, queryTimeoutUnits, @@ -68,7 +68,7 @@ public abstract class AbstractStreamOperation sync(UnitOfWork uow) throws TimeoutException { + public Stream sync(UnitOfWork uow) {//throws TimeoutException { if (uow == null) return sync(); @@ -105,11 +105,11 @@ public abstract class AbstractStreamOperation> async() { return CompletableFuture.>supplyAsync(() -> { - try { +// try { return sync(); - } catch (TimeoutException ex) { - throw new CompletionException(ex); - } +// } catch (TimeoutException ex) { +// throw new CompletionException(ex); +// } }); } @@ -117,11 +117,11 @@ public abstract class AbstractStreamOperation>supplyAsync(() -> { - try { +// try { return sync(); - } catch (TimeoutException ex) { - throw new CompletionException(ex); - } +// } catch (TimeoutException ex) { +// throw new CompletionException(ex); +// } }); } } diff --git a/src/main/java/net/helenus/core/operation/InsertOperation.java b/src/main/java/net/helenus/core/operation/InsertOperation.java index c92dac4..0f08c20 100644 --- a/src/main/java/net/helenus/core/operation/InsertOperation.java +++ b/src/main/java/net/helenus/core/operation/InsertOperation.java @@ -237,7 +237,7 @@ public final class InsertOperation extends AbstractOperation { } public ResultSet execute(AbstractSessionOperations session, UnitOfWork uow, TraceContext traceContext, long timeout, - TimeUnit units, boolean showValues, boolean cached) throws TimeoutException { + TimeUnit units, boolean showValues, boolean cached) { //throws TimeoutException { // Start recording in a Zipkin sub-span our execution time to perform this // operation. @@ -68,7 +68,7 @@ public abstract class Operation { Statement statement = options(buildStatement(cached)); ResultSetFuture futureResultSet = session.executeAsync(statement, showValues); - return futureResultSet.getUninterruptibly(timeout, units); + return futureResultSet.getUninterruptibly(); //TODO(gburd): (timeout, units); } finally { if (span != null) { diff --git a/src/main/java/net/helenus/core/operation/UpdateOperation.java b/src/main/java/net/helenus/core/operation/UpdateOperation.java index e7a2822..201365d 100644 --- a/src/main/java/net/helenus/core/operation/UpdateOperation.java +++ b/src/main/java/net/helenus/core/operation/UpdateOperation.java @@ -570,13 +570,12 @@ public final class UpdateOperation extends AbstractFilterOperation