Skip to content

Commit d4af725

Browse files
duoyulimalafeev
authored andcommitted
fix getReactiveConnection() (opentracing-contrib#43)
RedisConnectionFactory cant castcannot be cask to ReactiveRedisConnection
1 parent 2d514e9 commit d4af725

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

opentracing-redis-spring-data2/src/main/java/io/opentracing/contrib/redis/spring/data2/connection/TracingRedisConnectionFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public DataAccessException translateExceptionIfPossible(RuntimeException e) {
7272
@Override
7373
public ReactiveRedisConnection getReactiveConnection() {
7474
if (delegate instanceof ReactiveRedisConnectionFactory) {
75-
return new TracingReactiveRedisConnection((ReactiveRedisConnection) delegate,
75+
return new TracingReactiveRedisConnection(((ReactiveRedisConnectionFactory) delegate).getReactiveConnection(),
7676
tracingConfiguration);
7777
}
7878
// TODO: shouldn't we throw an exception?

0 commit comments

Comments
 (0)