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.git
The following commit(s) were added to refs/heads/main by this push:
new 9ecd452771 chore: safer EventEnvelope.toString (#2751)
9ecd452771 is described below
commit 9ecd4527710f10bd6d310ef2973cdf51e06fcbcd
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Mar 18 10:02:28 2026 +0100
chore: safer EventEnvelope.toString (#2751)
* Initial plan
* chore: safer EventEnvelope.toString - show class names instead of objects
Co-authored-by: pjfanning <[email protected]>
---------
Co-authored-by: copilot-swe-agent[bot]
<[email protected]>
Co-authored-by: pjfanning <[email protected]>
---
.../org/apache/pekko/persistence/query/EventEnvelope.scala | 9 +++++++--
.../pekko/persistence/query/typed/EventEnvelope.scala | 13 +++++++++++--
2 files changed, 18 insertions(+), 4 deletions(-)
diff --git
a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/EventEnvelope.scala
b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/EventEnvelope.scala
index c067e992c2..afda07fbdc 100644
---
a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/EventEnvelope.scala
+++
b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/EventEnvelope.scala
@@ -85,8 +85,13 @@ final class EventEnvelope(
case _ => false
}
- override def toString: String =
-
s"EventEnvelope($offset,$persistenceId,$sequenceNr,$event,$timestamp,$eventMetadata)"
+ override def toString: String = {
+ val metaStr = eventMetadata match {
+ case Some(meta) => meta.getClass.getName
+ case None => ""
+ }
+
s"EventEnvelope($offset,$persistenceId,$sequenceNr,${event.getClass.getName},$timestamp,$metaStr)"
+ }
// for binary compatibility (used to be a case class)
def copy(
diff --git
a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventEnvelope.scala
b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventEnvelope.scala
index a87ccbf198..0a48ee0e3a 100644
---
a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventEnvelope.scala
+++
b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/typed/EventEnvelope.scala
@@ -121,6 +121,15 @@ final class EventEnvelope[Event](
case _ => false
}
- override def toString: String =
-
s"EventEnvelope($offset,$persistenceId,$sequenceNr,$eventOption,$timestamp,$eventMetadata,$entityType,$slice)"
+ override def toString: String = {
+ val eventStr = eventOption match {
+ case Some(evt) => evt.getClass.getName
+ case None => ""
+ }
+ val metaStr = eventMetadata match {
+ case Some(meta) => meta.getClass.getName
+ case None => ""
+ }
+
s"EventEnvelope($offset,$persistenceId,$sequenceNr,$eventStr,$timestamp,$metaStr,$entityType,$slice)"
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
