This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/master by this push:
new a339753fed Pulsar Queue - resolve warning: "method stop in trait
Control is deprecated (since 2.7.1): This method is blocking. Use `complete`
instead" (#2349)
a339753fed is described below
commit a339753fed98a8ccde5d92d188f01bd5471f57ed
Author: vttran <vtt...@linagora.com>
AuthorDate: Tue Jul 16 21:42:20 2024 +0700
Pulsar Queue - resolve warning: "method stop in trait Control is deprecated
(since 2.7.1): This method is blocking. Use `complete` instead" (#2349)
---
.../scala/org/apache/james/queue/pulsar/PulsarMailQueue.scala | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/server/queue/queue-pulsar/src/main/scala/org/apache/james/queue/pulsar/PulsarMailQueue.scala
b/server/queue/queue-pulsar/src/main/scala/org/apache/james/queue/pulsar/PulsarMailQueue.scala
index 6f1a3bb891..f11fe39506 100644
---
a/server/queue/queue-pulsar/src/main/scala/org/apache/james/queue/pulsar/PulsarMailQueue.scala
+++
b/server/queue/queue-pulsar/src/main/scala/org/apache/james/queue/pulsar/PulsarMailQueue.scala
@@ -397,10 +397,10 @@ class PulsarMailQueue(
override def close(): Unit = {
enqueue.complete()
requeue.complete()
- dequeueControl.stop()
- scheduledConsumerControl.stop()
- filtersCommandFlowControl.stop()
- scheduledFiltersCommandFlowControl.stop()
+ dequeueControl.complete()
+ scheduledConsumerControl.complete()
+ filtersCommandFlowControl.complete()
+ scheduledFiltersCommandFlowControl.complete()
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org
