chibenwa commented on a change in pull request #498:
URL: https://github.com/apache/james-project/pull/498#discussion_r654362935
##########
File path:
server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueBrowser.java
##########
@@ -131,6 +131,14 @@ public CassandraMailQueueItemView next() {
.flatMapSequential(slice -> browseSlice(queueName, slice));
}
+ Flux<EnqueuedItemWithSlicingContext> browseReferences(MailQueueName
queueName, Instant start, Instant end) {
+ return allSlicesStartingAt(start)
+ .doOnNext(n -> System.out.println(" --- " + n + " slice looked
up"))
Review comment:
True I moved away from it.
We can remove it.
Rationnals: as items prior browse start are all marked as deleted, then
browse is not returning them. I had to use another strategy.
Please @Arsnael can you remove it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
