Skip to content

Commit cd7fac0

Browse files
author
psw0946
committed
[agent.java] reactor-core library version up
1 parent 46112c2 commit cd7fac0

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

scouter.agent.java/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,7 @@
332332
<dependency>
333333
<groupId>io.projectreactor</groupId>
334334
<artifactId>reactor-core</artifactId>
335-
<version>3.3.8.RELEASE</version>
335+
<version>3.4.35</version>
336336
<scope>provided</scope>
337337
</dependency>
338338
<dependency>

scouter.agent.java/src/main/java/reactor/core/publisher/ScouterOptimizableOperatorProxy.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,12 +54,12 @@ public static Tuple.StringLongPair nameOnCheckpoint(Object candidate, int maxSca
5454
}
5555
if (closeAssembly instanceof MonoOnAssembly) {
5656
FluxOnAssembly.AssemblySnapshot snapshot = ((MonoOnAssembly) closeAssembly).stacktrace;
57-
if (snapshot != null && snapshot.checkpointed) {
57+
if (snapshot != null && snapshot.isCheckpoint()) {
5858
return new Tuple.StringLongPair(snapshot.cached, snapshot.hashCode());
5959
}
6060
} else if (closeAssembly instanceof FluxOnAssembly) {
6161
FluxOnAssembly.AssemblySnapshot snapshot = ((FluxOnAssembly) closeAssembly).snapshotStack;
62-
if (snapshot != null && snapshot.checkpointed) {
62+
if (snapshot != null && snapshot.isCheckpoint()) {
6363
return new Tuple.StringLongPair(snapshot.cached, snapshot.hashCode());
6464
}
6565
}

scouter.agent.java/src/main/java/scouter/xtra/reactive/ReactiveSupport.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public Object subscriptOnContext(Object mono0, final TraceContext traceContext)
5858
}
5959
Mono<?> mono = (Mono<?>) mono0;
6060
traceContext.isReactiveTxidMarked = true;
61-
return mono.subscriberContext(new Function<Context, Context>() {
61+
return mono.contextWrite(new Function<Context, Context>() {
6262
@Override
6363
public Context apply(Context context) {
6464
return context.put(TraceContext.class, traceContext);

scouter.agent.java/src/main/java/scouter/xtra/reactive/ReactiveSupportWithCoroutine.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ public Object subscriptOnContext(Object mono0, final TraceContext traceContext)
6161
}
6262
Mono<?> mono = (Mono<?>) mono0;
6363
traceContext.isReactiveTxidMarked = true;
64-
return mono.subscriberContext(new Function<Context, Context>() {
64+
return mono.contextWrite(new Function<Context, Context>() {
6565
@Override
6666
public Context apply(Context context) {
6767
return context.put(TraceContext.class, traceContext);

0 commit comments

Comments
 (0)