You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by rc...@apache.org on 2021/07/08 08:47:53 UTC
[james-project] branch master updated (d0f043a -> 67d621d)
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git.
from d0f043a JAMES-3516 Using MimeMessageHeadersUtil to get needed headers input for ThreadIdGuessingAlgorithm::guessThreadId
add 47e5e0e JAMES-3605 Each Dequeuer flux should rely on its own receiver
add 5d297f0 JAMES-3605 Restart the eventBus upon reconnection
add e392431 JAMES-3605 Add a log upon RabbitMQ connection replacement
add 6fea981 JAMES-3605 Reconnection handling for MailQueue consumers
add c290a79 JAMES-3605 Reconnection handling for Distributed Task manager
add 67d621d JAMES-3605 Reconnection handling should rely on Init operation
No new revisions were added by this update.
Summary of changes:
.../backends/rabbitmq/SimpleConnectionPool.java | 19 +++++++++++---
.../james/backends/rabbitmq/RabbitMQExtension.java | 3 ---
.../james/events/EventBusReconnectionHandler.java | 21 ++++++++++++----
.../org/apache/james/events/GroupRegistration.java | 22 +++++++++++-----
.../james/events/GroupRegistrationHandler.java | 26 ++++++++++++-------
.../james/events/KeyRegistrationHandler.java | 26 +++++++++++++------
.../org/apache/james/events/RabbitMQEventBus.java | 5 ++++
.../transport/mailets/AmqpForwardAttribute.java | 5 +---
.../rabbitmq/host/RabbitMQEventBusHostSystem.java | 5 +---
.../james/modules/event/JMAPEventBusModule.java | 6 +++++
.../modules/event/RabbitMQEventBusModule.java | 2 ++
server/container/guice/queue/rabbitmq/pom.xml | 4 +++
.../modules/queue/rabbitmq/RabbitMQModule.java | 14 ++++++++++-
.../rabbitmq/SpoolerReconnectionHandler.java} | 17 +++++++++----
.../mailetcontainer/impl/JamesMailSpooler.java | 9 ++++++-
.../org/apache/james/queue/rabbitmq/Dequeuer.java | 26 +++++++++----------
.../james/queue/rabbitmq/RabbitMQMailQueue.java | 2 +-
.../distributed/RabbitMQTerminationSubscriber.java | 23 +++++++++++------
.../distributed/RabbitMQWorkQueue.java | 29 +++++++++++++++-------
.../RabbitMQWorkQueueReconnectionHandler.java | 22 ++++++++++------
.../TerminationReconnectionHandler.java | 21 ++++++++++------
.../main/java/org/apache/james/task/WorkQueue.java | 4 +++
.../eventsourcing/EventSourcingTaskManager.scala | 4 +--
23 files changed, 216 insertions(+), 99 deletions(-)
copy server/container/guice/mailbox/src/test/java/org/apache/james/modules/mailbox/NoopPreDeletionHook.java => event-bus/distributed/src/main/java/org/apache/james/events/EventBusReconnectionHandler.java (68%)
copy server/container/guice/{mailet/src/main/java/org/apache/james/utils/SpoolerProbe.java => queue/rabbitmq/src/main/java/org/apache/james/modules/queue/rabbitmq/SpoolerReconnectionHandler.java} (72%)
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org