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 d9ca03f5e fix typo for sourceActorSystem and mistake package name
(#641)
d9ca03f5e is described below
commit d9ca03f5e9b7d8f4b53c945d933fd169c749d8b3
Author: Laglangyue <[email protected]>
AuthorDate: Mon Apr 29 20:07:30 2024 +0800
fix typo for sourceActorSystem and mistake package name (#641)
* fix typo for sourceActorSystem
* fix mistake package
---
.../src/test/scala/docs/scaladsl/MqttFlowSpec.scala | 2 +-
.../pekko/stream/connectors/testkit/CapturingAppender.scala | 4 ++--
.../stream/connectors/testkit/scaladsl/LogCapturing.scala | 12 ++++++------
3 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/mqtt-streaming/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
b/mqtt-streaming/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
index fd73bfa50..ecb419eea 100644
--- a/mqtt-streaming/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
+++ b/mqtt-streaming/src/test/scala/docs/scaladsl/MqttFlowSpec.scala
@@ -48,7 +48,7 @@ class TypedMqttFlowSpec
abstract class MqttFlowSpecBase(clientId: String, topic: String, system:
ActorSystem) extends TestKit(system)
with AnyWordSpecLike with Matchers with BeforeAndAfterAll with
ScalaFutures with LogCapturing {
- override def sourceActorSytem = Some(system.name)
+ override def sourceActorSystem = Some(system.name)
private implicit val defaultPatience: PatienceConfig =
PatienceConfig(timeout = 5.seconds, interval = 100.millis)
diff --git
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
index c922c87d0..7ced4816c 100644
---
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
+++
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
@@ -56,8 +56,8 @@ import org.slf4j.LoggerFactory
* the captured logging events are flushed to the appenders defined for the
* org.apache.pekko.actor.testkit.typed.internal.CapturingAppenderDelegate
logger.
*
- * The flushing on test failure is handled by
[[pekko.actor.testkit.typed.scaladsl.LogCapturing]]
- * for ScalaTest and [[pekko.actor.testkit.typed.javadsl.LogCapturing]] for
JUnit.
+ * The flushing on test failure is handled by
[[org.apache.pekko.actor.testkit.typed.scaladsl.LogCapturing]]
+ * for ScalaTest and
[[org.apache.pekko.actor.testkit.typed.javadsl.LogCapturing]] for JUnit.
*
* Use configuration like the following the logback-test.xml:
*
diff --git
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
index d63c64684..5af8db8cd 100644
---
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
+++
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
@@ -44,7 +44,7 @@ import org.slf4j.MDC
trait LogCapturing extends BeforeAndAfterAll { self: TestSuite =>
// Can be overridden to filter on sourceActorSystem
- def sourceActorSytem: Option[String] = None
+ def sourceActorSystem: Option[String] = None
// eager access of CapturingAppender to fail fast if misconfigured
private val capturingAppender = CapturingAppender.get("")
@@ -64,18 +64,18 @@ trait LogCapturing extends BeforeAndAfterAll { self:
TestSuite =>
}
abstract override def withFixture(test: NoArgTest): Outcome = {
- sourceActorSytem.foreach(MDC.put("sourceActorSystem", _))
+ sourceActorSystem.foreach(MDC.put("sourceActorSystem", _))
myLogger.info(s"Logging started for test [${self.getClass.getName}:
${test.name}]")
- sourceActorSytem.foreach(_ => MDC.remove("sourceActorSystem"))
+ sourceActorSystem.foreach(_ => MDC.remove("sourceActorSystem"))
val res = test()
- sourceActorSytem.foreach(MDC.put("sourceActorSystem", _))
+ sourceActorSystem.foreach(MDC.put("sourceActorSystem", _))
myLogger.info(s"Logging finished for test [${self.getClass.getName}:
${test.name}] that [$res]")
- sourceActorSytem.foreach(_ => MDC.remove("sourceActorSystem"))
+ sourceActorSystem.foreach(_ => MDC.remove("sourceActorSystem"))
if (!(res.isSucceeded || res.isPending)) {
println(
s"--> [${Console.BLUE}${self.getClass.getName}:
${test.name}${Console.RESET}] Start of log messages of test that [$res]")
- capturingAppender.flush(sourceActorSytem)
+ capturingAppender.flush(sourceActorSystem)
println(
s"<-- [${Console.BLUE}${self.getClass.getName}:
${test.name}${Console.RESET}] End of log messages of test that [$res]")
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
