akka 2.5 does not support toArrayUnsafe()

kamon-io · Oct 2, 2024 · 5f3ce78 · 5f3ce78
1 parent b75ad9d
commit 5f3ce78
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...strumentation/pekko/remote/internal/PekkoPduProtobufCodecDecodeMessageMethodAdvisor.scala b/...strumentation/pekko/remote/internal/PekkoPduProtobufCodecDecodeMessageMethodAdvisor.scala
@@ -24,7 +24,7 @@ object PekkoPduProtobufCodecDecodeMessage {
     @Argument(1) provider: RemoteActorRefProvider,
     @Argument(2) localAddress: Address
   ): Unit = {
-    val ackAndEnvelope = AckAndContextAwareEnvelopeContainer.parseFrom(bs.toArrayUnsafe())
+    val ackAndEnvelope = AckAndContextAwareEnvelopeContainer.parseFrom(bs.toArray)
     if (ackAndEnvelope.hasEnvelope && ackAndEnvelope.getEnvelope.hasTraceContext) {
       val remoteCtx = ackAndEnvelope.getEnvelope.getTraceContext