Skip to content

Commit 3bdb085

Browse files
committed
Add timestamp() to super stream consumer context
1 parent 8ed0adc commit 3bdb085

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/main/java/com/rabbitmq/stream/impl/SuperStreamConsumer.java

+5
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,11 @@ public long offset() {
110110
return context.offset();
111111
}
112112

113+
@Override
114+
public long timestamp() {
115+
return context.timestamp();
116+
}
117+
113118
@Override
114119
public void storeOffset() {
115120
for (ConsumerState state : consumerStates) {

0 commit comments

Comments
 (0)