You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cs...@apache.org on 2021/12/20 12:46:12 UTC
[sling-org-apache-sling-distribution-journal-messages] 01/01: SLING-11028 - Allow to assign to relative offsets
This is an automated email from the ASF dual-hosted git repository.
cschneider pushed a commit to branch SLING-11028
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal-messages.git
commit 42871b6fc10bba6700f710e1b6106e7142c4328d
Author: Christian Schneider <cs...@adobe.com>
AuthorDate: Mon Dec 20 13:43:00 2021 +0100
SLING-11028 - Allow to assign to relative offsets
---
.../java/org/apache/sling/distribution/journal/MessagingProvider.java | 2 ++
src/main/java/org/apache/sling/distribution/journal/Reset.java | 1 +
src/main/java/org/apache/sling/distribution/journal/package-info.java | 2 +-
3 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/src/main/java/org/apache/sling/distribution/journal/MessagingProvider.java b/src/main/java/org/apache/sling/distribution/journal/MessagingProvider.java
index 6b77f52..c3e2f21 100644
--- a/src/main/java/org/apache/sling/distribution/journal/MessagingProvider.java
+++ b/src/main/java/org/apache/sling/distribution/journal/MessagingProvider.java
@@ -40,6 +40,8 @@ public interface MessagingProvider {
String assignTo(long offset);
+ String assignTo(Reset reset, long relativeOffset);
+
/**
* Return the uri of the messaging system backend.
* The uri must be unique regarding the validity of per topic offsets.
diff --git a/src/main/java/org/apache/sling/distribution/journal/Reset.java b/src/main/java/org/apache/sling/distribution/journal/Reset.java
index 283a7d4..695d5fe 100644
--- a/src/main/java/org/apache/sling/distribution/journal/Reset.java
+++ b/src/main/java/org/apache/sling/distribution/journal/Reset.java
@@ -18,4 +18,5 @@
*/
package org.apache.sling.distribution.journal;
+// Do not change the enum names. Implementation depends on the exact names.
public enum Reset { earliest, latest }
\ No newline at end of file
diff --git a/src/main/java/org/apache/sling/distribution/journal/package-info.java b/src/main/java/org/apache/sling/distribution/journal/package-info.java
index 8f0ad89..b64492c 100644
--- a/src/main/java/org/apache/sling/distribution/journal/package-info.java
+++ b/src/main/java/org/apache/sling/distribution/journal/package-info.java
@@ -16,6 +16,6 @@
* specific language governing permissions and limitations
* under the License.
*/
-@org.osgi.annotation.versioning.Version("1.3.0")
+@org.osgi.annotation.versioning.Version("1.4.0")
package org.apache.sling.distribution.journal;