Skip to content

Commit 5f24a73

Browse files
authored
fix api change through direct connection call (#4232)
1 parent fb4d1e8 commit 5f24a73

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

apm-agent-plugins/apm-redis-plugin/apm-lettuce-plugin/src/test/java/co/elastic/apm/agent/lettuce/Lettuce5InstrumentationIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,9 +75,9 @@ public void testAsyncLettuce() throws Exception {
7575
public void testBatchedLettuce() throws Exception {
7676
RedisAsyncCommands<String, String> async = connection.async();
7777
async.set("foo", "bar").get();
78-
async.setAutoFlushCommands(false);
78+
connection.setAutoFlushCommands(false);
7979
List<RedisFuture<String>> futures = List.of(async.get("foo"), async.get("foo"));
80-
async.flushCommands();
80+
connection.flushCommands();
8181
LettuceFutures.awaitAll(Duration.ofSeconds(5), futures.toArray(new RedisFuture[0]));
8282
assertTransactionWithRedisSpans("SET", "GET", "GET");
8383
}

0 commit comments

Comments
 (0)