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 e693af36b1
commit a830c92cf6
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

@@ -34,6 +34,7 @@ import org.springframework.util.Assert;
import com.datastax.driver.core.*;
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
@@ -156,7 +157,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);
}