From 636a80387e143579f75bc517021c236e143396f3 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Fri, 14 Feb 2025 23:28:48 +0100 Subject: [PATCH 1/4] new CurrentLastKnownSequenceNumberByPersistenceIdQuery --- ...wnSequenceNumberByPersistenceIdQuery.scala | 36 +++++++++++++++++++ ...wnSequenceNumberByPersistenceIdQuery.scala | 33 +++++++++++++++++ 2 files changed, 69 insertions(+) create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala create mode 100644 persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala diff --git a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala new file mode 100644 index 00000000000..d3ebb2c76a9 --- /dev/null +++ b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.pekko.persistence.query.javadsl + +import java.util.Optional +import java.util.concurrent.CompletionStage + +/** + * A trait that enables querying the current last known sequence number for a given `persistenceId`. + * @since 1.2.0 + */ +trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { + +/** + * Returns the last known sequence number for the given `persistenceId`. Empty if the `persistenceId` is unknown. + * + * @param persistenceId The `persistenceId` for which the last known sequence number should be returned. + * @return Some sequence number or None if the `persistenceId` is unknown. + */ + def currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): CompletionStage[Optional[Long]] +} diff --git a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala new file mode 100644 index 00000000000..a84451060d4 --- /dev/null +++ b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.pekko.persistence.query.scaladsl + +/** + * A trait that enables querying the current last known sequence number for a given `persistenceId`. + * @since 1.2.0 + */ +trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { + +/** + * Returns the last known sequence number for the given `persistenceId`. Empty if the `persistenceId` is unknown. + * + * @param persistenceId The `persistenceId` for which the last known sequence number should be returned. + * @return Some sequence number or None if the `persistenceId` is unknown. + */ + def currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): Future[Option[Long]] +} From d19d5e22ff3ea20825fdd16add61d4c76212f474 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Sun, 16 Feb 2025 13:16:36 +0100 Subject: [PATCH 2/4] java Long --- .../CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala | 4 ++-- .../CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala index d3ebb2c76a9..b86b8c5ad80 100644 --- a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala +++ b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala @@ -26,11 +26,11 @@ import java.util.concurrent.CompletionStage */ trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { -/** + /** * Returns the last known sequence number for the given `persistenceId`. Empty if the `persistenceId` is unknown. * * @param persistenceId The `persistenceId` for which the last known sequence number should be returned. * @return Some sequence number or None if the `persistenceId` is unknown. */ - def currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): CompletionStage[Optional[Long]] + def currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): CompletionStage[Optional[java.lang.Long]] } diff --git a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala index a84451060d4..e6ce883c6bf 100644 --- a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala +++ b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala @@ -23,7 +23,7 @@ package org.apache.pekko.persistence.query.scaladsl */ trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { -/** + /** * Returns the last known sequence number for the given `persistenceId`. Empty if the `persistenceId` is unknown. * * @param persistenceId The `persistenceId` for which the last known sequence number should be returned. From 879b86c16c0194830aa9d50a6b6bbc7783356589 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Sun, 16 Feb 2025 13:30:39 +0100 Subject: [PATCH 3/4] Update CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala --- .../CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala index e6ce883c6bf..9b65f2461f5 100644 --- a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala +++ b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala @@ -17,6 +17,8 @@ package org.apache.pekko.persistence.query.scaladsl +import scala.concurrent.Future + /** * A trait that enables querying the current last known sequence number for a given `persistenceId`. * @since 1.2.0 From 33ba6a7dbb2fa5b101b59164761ab122234695e3 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Thu, 20 Feb 2025 11:48:19 +0100 Subject: [PATCH 4/4] rename traits and functions --- ... => CurrentLastSequenceNumberByPersistenceIdQuery.scala} | 6 +++--- ... => CurrentLastSequenceNumberByPersistenceIdQuery.scala} | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) rename persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/{CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala => CurrentLastSequenceNumberByPersistenceIdQuery.scala} (80%) rename persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/{CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala => CurrentLastSequenceNumberByPersistenceIdQuery.scala} (81%) diff --git a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastSequenceNumberByPersistenceIdQuery.scala similarity index 80% rename from persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala rename to persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastSequenceNumberByPersistenceIdQuery.scala index b86b8c5ad80..58c9c89e3eb 100644 --- a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala +++ b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/javadsl/CurrentLastSequenceNumberByPersistenceIdQuery.scala @@ -21,10 +21,10 @@ import java.util.Optional import java.util.concurrent.CompletionStage /** - * A trait that enables querying the current last known sequence number for a given `persistenceId`. + * A trait that enables querying the current last sequence number for a given `persistenceId`. * @since 1.2.0 */ -trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { +trait CurrentLastSequenceNumberByPersistenceIdQuery extends ReadJournal { /** * Returns the last known sequence number for the given `persistenceId`. Empty if the `persistenceId` is unknown. @@ -32,5 +32,5 @@ trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { * @param persistenceId The `persistenceId` for which the last known sequence number should be returned. * @return Some sequence number or None if the `persistenceId` is unknown. */ - def currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): CompletionStage[Optional[java.lang.Long]] + def currentLastSequenceNumberByPersistenceId(persistenceId: String): CompletionStage[Optional[java.lang.Long]] } diff --git a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastSequenceNumberByPersistenceIdQuery.scala similarity index 81% rename from persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala rename to persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastSequenceNumberByPersistenceIdQuery.scala index 9b65f2461f5..9a61b61a338 100644 --- a/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastKnownSequenceNumberByPersistenceIdQuery.scala +++ b/persistence-query/src/main/scala/org/apache/pekko/persistence/query/scaladsl/CurrentLastSequenceNumberByPersistenceIdQuery.scala @@ -20,10 +20,10 @@ package org.apache.pekko.persistence.query.scaladsl import scala.concurrent.Future /** - * A trait that enables querying the current last known sequence number for a given `persistenceId`. + * A trait that enables querying the current last sequence number for a given `persistenceId`. * @since 1.2.0 */ -trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { +trait CurrentLastSequenceNumberByPersistenceIdQuery extends ReadJournal { /** * Returns the last known sequence number for the given `persistenceId`. Empty if the `persistenceId` is unknown. @@ -31,5 +31,5 @@ trait CurrentLastKnownSequenceNumberByPersistenceIdQuery extends ReadJournal { * @param persistenceId The `persistenceId` for which the last known sequence number should be returned. * @return Some sequence number or None if the `persistenceId` is unknown. */ - def currentLastKnownSequenceNumberByPersistenceId(persistenceId: String): Future[Option[Long]] + def currentLastSequenceNumberByPersistenceId(persistenceId: String): Future[Option[Long]] }