SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Implements new methods and delegates them.

Browse Source
This commit is contained in:
spencergibb
2021-07-09 14:55:27 -04:00
parent b5c4aa256d
commit 602749a8d1
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/cassandra/TraceReactiveSession.java
View File

@@ -19,10 +19,12 @@ package org.springframework.cloud.sleuth.instrument.cassandra;
import java.util.Map;
import java.util.Optional;
import com.datastax.oss.driver.api.core.CqlIdentifier;
import com.datastax.oss.driver.api.core.context.DriverContext;
import com.datastax.oss.driver.api.core.cql.PreparedStatement;
import com.datastax.oss.driver.api.core.cql.SimpleStatement;
import com.datastax.oss.driver.api.core.cql.Statement;
import com.datastax.oss.driver.api.core.metadata.Metadata;
import reactor.core.publisher.Mono;
import reactor.util.context.ContextView;
@@ -77,6 +79,16 @@ public class TraceReactiveSession implements ReactiveSession {
return this.delegate.getContext();
}
@Override
public Optional<CqlIdentifier> getKeyspace() {
return this.delegate.getKeyspace();
}
@Override
public Metadata getMetadata() {
return this.delegate.getMetadata();
}
@Override
public Mono<ReactiveResultSet> execute(String cql) {
return execute(SimpleStatement.newInstance(cql));