Spring/spring-data-cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACASS-599 - Restore compatibility with Guava 26+.

Browse Source 
Guava has removed Futures#transform method without the Executor parameter in version 26.0-jre
DefaultBridgeReactiveSession fails with NoSuchMethod exception when used with Guava 26.0-jre+.

Original pull request: #137.
This commit is contained in:
Mateusz Stefek
2019-02-06 10:56:31 +01:00
committed by Mark Paluch
parent 43ed6e6571
commit 849af2c085
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-data-cassandra/src/main/java/org/springframework/data/cassandra/core/cql/session/DefaultBridgedReactiveSession.java
View File

@@ -44,6 +44,7 @@ import com.datastax.driver.core.SimpleStatement;
import com.datastax.driver.core.Statement;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.MoreExecutors;
/**
* Default implementation of a {@link ReactiveSession}. This implementation bridges asynchronous {@link Session} methods
@@ -166,7 +167,7 @@ public class DefaultBridgedReactiveSession implements ReactiveSession {
ListenableFuture<ResultSet> future = this.session.executeAsync(statement);
ListenableFuture<ReactiveResultSet> resultSetFuture =
Futures.transform(future, DefaultReactiveResultSet::new);
Futures.transform(future, DefaultReactiveResultSet::new, MoreExecutors.directExecutor());
adaptFuture(resultSetFuture, sink);
}