This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 8488fc583 jms: safe to create ByteString from array with copying
(#1229)
8488fc583 is described below
commit 8488fc5837a338c896bb2056f006d7f28e230e44
Author: PJ Fanning <[email protected]>
AuthorDate: Sun Oct 12 22:11:57 2025 +0200
jms: safe to create ByteString from array with copying (#1229)
---
.../pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala | 2 +-
.../org/apache/pekko/stream/connectors/jms/impl/JmsMessageReader.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala
b/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala
index 21fc33e63..cd4fae6b4 100644
---
a/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala
+++
b/jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl/JmsMessageReader.scala
@@ -40,7 +40,7 @@ private[jakartams] object JmsMessageReader {
else {
val len = message.readBytes(buff)
val d = buff.take(len)
- read(data ++ ByteString(d))
+ read(data ++ ByteString.fromArrayUnsafe(d))
}
read(ByteString.empty)
}
diff --git
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageReader.scala
b/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageReader.scala
index 40799c758..19710d5b0 100644
---
a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageReader.scala
+++
b/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageReader.scala
@@ -41,7 +41,7 @@ private[jms] object JmsMessageReader {
else {
val len = message.readBytes(buff)
val d = buff.take(len)
- read(data ++ ByteString(d))
+ read(data ++ ByteString.fromArrayUnsafe(d))
}
read(ByteString.empty)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
