fix typo in Projection and CassandraProjection (#243)

apache · Jan 8, 2025 · 33c22a9 · 33c22a9
1 parent cc87b5c
commit 33c22a9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...a/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala b/...a/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
@@ -153,7 +153,7 @@ object CassandraProjection {
 
   /**
    * For testing purposes the projection offset and management tables can be created programmatically.
-   * For production it's recommended to create the table with DDL statements
+   * For production, it's recommended to create the table with DDL statements
    * before the system is started.
    */
   def createTablesIfNotExists()(implicit system: ActorSystem[_]): Future[Done] = {

diff --git a/core/src/main/scala/org/apache/pekko/projection/Projection.scala b/core/src/main/scala/org/apache/pekko/projection/Projection.scala
@@ -108,7 +108,7 @@ trait Projection[Envelope] {
 private[projection] object RunningProjection {
 
   /**
-   * When stopping an projection the retry mechanism is aborted via this exception.
+   * When stopping a projection the retry mechanism is aborted via this exception.
    */
   case object AbortProjectionException extends RuntimeException("Projection aborted.") with NoStackTrace