You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2026/03/18 09:02:34 UTC
(pekko) branch main updated: chore: safer EventEnvelope.toString (#2751)
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 <pj...@users.noreply.github.com>
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 <11...@users.noreply.github.com>
---------
Co-authored-by: copilot-swe-agent[bot] <19...@users.noreply.github.com>
Co-authored-by: pjfanning <11...@users.noreply.github.com>
---
.../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: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org