|
Change Return Type FluentFutureStream<EnqueuedItemWithSlicingContext> to Flux<EnqueuedItemWithSlicingContext> in method package browseReferences(queueName MailQueueName) : Flux<EnqueuedItemWithSlicingContext> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueBrowser |
From |
To |
|
Change Return Type FluentFutureStream<EnqueuedItemWithSlicingContext> to Mono<List<EnqueuedItemWithSlicingContext>> in method private browseSlice(queueName MailQueueName, slice Slice) : Mono<List<EnqueuedItemWithSlicingContext>> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueBrowser |
From |
To |
|
Change Return Type CompletableFuture<Optional<Instant>> to Mono<Instant> in method private findNewBrowseStart(mailQueueName MailQueueName) : Mono<Instant> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueMailDelete |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package insert(enqueuedItemWithSlicing EnqueuedItemWithSlicingContext) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.EnqueuedMailsDAO |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package markAsDeleted(mailQueueName MailQueueName, mailKey MailKey) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.DeletedMailsDAO |
From |
To |
|
Change Return Type CompletableFuture<Long> to long in method public delete(deleteCondition DeleteCondition) : long in class org.apache.james.queue.rabbitmq.view.api.MailQueueView |
From |
To |
|
Change Return Type CompletableFuture<Boolean> to Mono<Boolean> in method package isDeleted(mailQueueName MailQueueName, mailKey MailKey) : Mono<Boolean> in class org.apache.james.queue.rabbitmq.view.cassandra.DeletedMailsDAO |
From |
To |
|
Change Return Type CompletableFuture<Boolean> to Mono<Boolean> in method package isStillEnqueued(mailQueueName MailQueueName, mailKey MailKey) : Mono<Boolean> in class org.apache.james.queue.rabbitmq.view.cassandra.DeletedMailsDAO |
From |
To |
|
Change Return Type Stream<BucketId> to Flux<BucketId> in method private allBucketIds() : Flux<BucketId> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueBrowser |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package considerDeleted(mailKey MailKey, mailQueueName MailQueueName) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueMailDelete |
From |
To |
|
Change Return Type CompletableFuture<Stream<ManageableMailQueue.MailQueueItemView>> to Flux<ManageableMailQueue.MailQueueItemView> in method package browse(queueName MailQueueName) : Flux<ManageableMailQueue.MailQueueItemView> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueBrowser |
From |
To |
|
Change Return Type CompletableFuture<Void> to void in method package updateBrowseStart(mailQueueName MailQueueName) : void in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueMailDelete |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package insertInitialBrowseStart(mailQueueName MailQueueName, sliceStart Instant) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.BrowseStartDAO |
From |
To |
|
Change Return Type CompletableFuture<Mail> to Mono<Mail> in method private toMailFuture(enqueuedItemWithSlicingContext EnqueuedItemWithSlicingContext) : Mono<Mail> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueBrowser |
From |
To |
|
Change Return Type CompletableFuture<Optional<Instant>> to Mono<Instant> in method package findBrowseStart(queueName MailQueueName) : Mono<Instant> in class org.apache.james.queue.rabbitmq.view.cassandra.BrowseStartDAO |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method private delete(mailKey MailKey) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueView |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package storeMail(enqueuedItem EnqueuedItem) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueMailStore |
From |
To |
|
Change Return Type CompletableFuture<Long> to long in method public delete(deleteCondition DeleteCondition) : long in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueView |
From |
To |
|
Change Return Type FluentFutureStream<EnqueuedItemWithSlicingContext> to Flux<EnqueuedItemWithSlicingContext> in method private browseBucket(queueName MailQueueName, slice Slice, bucketId BucketId) : Flux<EnqueuedItemWithSlicingContext> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueBrowser |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package considerDeleted(mail Mail, mailQueueName MailQueueName) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueMailDelete |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package updateBrowseStart(mailQueueName MailQueueName, sliceStart Instant) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.BrowseStartDAO |
From |
To |
|
Change Return Type CompletableFuture<Boolean> to Mono<Boolean> in method package isDeleted(mail Mail, mailQueueName MailQueueName) : Mono<Boolean> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueMailDelete |
From |
To |
|
Change Return Type CompletableFuture<Stream<EnqueuedItemWithSlicingContext>> to Flux<EnqueuedItemWithSlicingContext> in method package selectEnqueuedMails(queueName MailQueueName, slice Slice, bucketId BucketId) : Flux<EnqueuedItemWithSlicingContext> in class org.apache.james.queue.rabbitmq.view.cassandra.EnqueuedMailsDAO |
From |
To |
|
Change Return Type CompletableFuture<Optional<Row>> to Mono<Row> in method package selectOne(queueName MailQueueName) : Mono<Row> in class org.apache.james.queue.rabbitmq.view.cassandra.BrowseStartDAO |
From |
To |
|
Change Return Type CompletableFuture<Void> to Mono<Void> in method package initializeBrowseStart(mailQueueName MailQueueName) : Mono<Void> in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueMailStore |
From |
To |
|
Change Return Type CompletableFuture<Long> to long in method private browseThenDelete(deleteCondition DeleteCondition) : long in class org.apache.james.queue.rabbitmq.view.cassandra.CassandraMailQueueView |
From |
To |