This is an automated email from the ASF dual-hosted git repository.
btellier pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git.
from 58af5c3 JAMES-3149 Reactive GetMessageList
new 58322e7 JAMES-3117 Add logs for HealthChecks for unhealthy/degraded
status
new 2e7b08b JAMES-3117 Add PeriodicalHealthChecks/Test
new 3b61bfa JAMES-3117 Add PeriodicalHealthChecksConfiguration/Test
new d73c003 JAMES-3117 Add healthcheck.propeties config file in guice
packages
new b7fb64a JAMES-3117 Refactor PeriodicalHealthChecks/Test for using
configuration
new 765d20a JAMES-3117 Guice wiring for PeriodicalHealthChecks
new d3c90b4 JAMES-3117 Update changelog
new d8ceefb JAMES-3117 Remove 'intialDelay', change 'period' to Duration
type
new 9c0e636 JAMES-3117 Use reactor test library for testing with virtual
time
new 3ba85a3 JAMES-3117 Add PeriodicalHealthChecksConfiguration/Test
new fbd6fc6 JAMES-3117 Add PeriodicalHealthChecksConfiguration/Test
new 48d1daf JAMES-3117 Add healthcheck.propeties config file in guice
packages
new 2cd0bdc JAMES-3117 Remove logging in all healthChecks.
new f8fe440 JAMES-3117 Add Builder in 'Result' class
new 215eca8 JAMES-3117 Add logging for callers of HealthChecks
new f3ec7e0 JAMES-3117 Remove Builder in 'Result' class
new 75a2b67 JAMES-3117 Add PeriodicalHealthChecks/Test
new f98c58f JAMES-3117 Add logging for callers of HealthChecks
new 985f27b JAMES-3117 Install PeriodicalHealthChecksModule in
CommonServicesModule
new 5f74bef JAMES-3117 Reactive HealthCheck
new a6ada75 JAMES-3137 Create a cache Keyspace
new 505d353 JAMES-3137 Inject a separate Cassandra session for cache
keyspace
new 9c27d70 JAMES-3137 Split responsibilities between guice & backend
new 41035e1 JAMES-3137 Move Cassandra cache session initialization to its
own module
new 4ad5014 JAMES-3134 Check RabbitMQ version at start up
new f16dff5 JAMES-3134 Update RabbitMQ related documentation
new e530af7 JAMES-3139 RabbitMQEventBus error dispatching tests
new ee06965 JAMES-3139 RabbitMQEventBus error dispatching handling
new 5801a79 JAMES-3139 reDeliver() DispatchingFailureGroup should deliver
events to all groups
new 083b54a JAMES-3139 DispatchingFailureGroup integration test
new 10cbd3e JAMES-3139 Speed up integration tests for Distributed James
new f6308a3 JAMES-3139 Decrease the hard coded retries before opening a
RabbitMQ connection
new 2f7bc3d JAMES-3143 Fix typo in Cassandra message inconsistency ADR
new 2feeea7 JAMES-3149 default method for mailbox counters
new 3943d2f JAMES-3149 reactify more getMailboxes
new cb1179e JAMES-3149 Reactive getMailboxes
new f9b3122 [REFACTORING] remove duplicate reactor scala extension
new 125c08e [REFACTORING] CassandraMessageIdToImapUidDAO never uses
cassandraUtils
new ee0028e JAMES-2897 Insert statements needs ifNotExist when LWT is
used in inserts
The 39 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGELOG.md | 3 +-
.../backends/cassandra/init/KeyspaceFactory.java | 19 +--
.../cassandra/init/ResilientClusterProvider.java | 4 +-
.../init/SessionWithInitializedTablesFactory.java | 18 +--
.../init/configuration/ClusterConfiguration.java | 67 +--------
.../init/configuration/InjectionNames.java | 5 +-
.../init/configuration/KeyspaceConfiguration.java | 98 +++++++++++++
.../cassandra/utils/CassandraAsyncExecutor.java | 6 +
.../cassandra/utils/CassandraHealthCheck.java | 25 ++--
.../james/backends/cassandra/CassandraCluster.java | 18 ++-
.../cassandra/CassandraClusterExtension.java | 13 ++
.../james/backends/cassandra/DockerCassandra.java | 63 ++++----
.../cassandra/DockerCassandraExtension.java | 6 +
.../backends/cassandra/DockerCassandraRule.java | 5 +
.../init/ResilientClusterProviderTest.java | 135 +++++-------------
.../SessionWithInitializedTablesFactoryTest.java | 5 +-
.../backends/es/ElasticSearchHealthCheck.java | 6 +-
.../backends/rabbitmq/RabbitMQHealthCheck.java | 25 ++--
.../backends/rabbitmq/RabbitMQServerVersion.java | 44 +++---
.../backends/rabbitmq/SimpleConnectionPool.java | 15 +-
.../rabbitmq/RabbitMQServerVersionTest.java | 96 +++++++++++++
.../apache/james/core/healthcheck/HealthCheck.java | 12 +-
.../org/apache/james/core/healthcheck/Result.java | 31 ++--
.../destination/conf/healthcheck.properties} | 25 +---
.../destination/conf/healthcheck.properties} | 25 +---
.../destination/conf/healthcheck.properties} | 25 +---
.../destination/conf/healthcheck.properties} | 25 +---
.../destination/conf/healthcheck.properties} | 25 +---
.../jpa/destination/conf/healthcheck.properties} | 25 +---
.../destination/conf/healthcheck.properties} | 25 +---
.../org/apache/james/mailbox/MailboxManager.java | 4 +
.../events/EventDeadLettersHealthCheck.java | 28 ++--
.../mail/CassandraMessageIdToImapUidDAO.java | 14 +-
.../cassandra/mail/CassandraMessageMapper.java | 16 +--
.../james/mailbox/events/EventDispatcher.java | 60 ++++++--
.../james/mailbox/events/RabbitMQEventBus.java | 18 ++-
.../james/mailbox/events/RabbitMQEventBusTest.java | 158 +++++++++++++++++++++
.../james/mailbox/jpa/mail/JPAMessageMapper.java | 8 --
.../jpa/mail/TransactionalMessageMapper.java | 6 -
.../mailbox/maildir/mail/MaildirMessageMapper.java | 9 --
.../inmemory/mail/InMemoryMessageMapper.java | 14 --
.../james/mailbox/store/StoreMailboxManager.java | 58 ++++----
.../james/mailbox/store/mail/MessageMapper.java | 7 +-
.../StoreMailboxMessageResultIteratorTest.java | 6 -
.../store/mail/model/MessageMapperTest.java | 18 ---
.../CassandraRabbitMQAwsS3SmtpTestRuleFactory.java | 8 ++
.../mpt/smtp/CassandraSmtpTestRuleFactory.java | 8 ++
pom.xml | 5 -
.../mailbox/CassandraCacheSessionModule.java | 84 +++++++++++
.../modules/mailbox/CassandraSessionModule.java | 46 +++++-
.../modules/mailbox/KeyspacesConfiguration.java | 155 ++++++++++++++++++++
.../org/apache/james/server/CassandraProbe.java | 9 +-
.../java/org/apache/james/CacheSessionTest.java | 102 +++++++++++++
.../java/org/apache/james/DockerCassandraRule.java | 10 +-
.../org/apache/james/KeyspaceCreationTest.java | 143 +++++++++++++++++++
.../mailbox/KeyspacesConfigurationTest.java} | 43 +++---
.../apache/james/modules/RabbitMQExtension.java | 12 ++
.../apache/james/modules/TestRabbitMQModule.java | 14 ++
server/container/guice/guice-common/pom.xml | 10 ++
.../org/apache/james/PeriodicalHealthChecks.java | 115 +++++++++++++++
.../james/PeriodicalHealthChecksConfiguration.java | 107 ++++++++++++++
.../apache/james/modules/CommonServicesModule.java | 1 +
.../modules/PeriodicalHealthChecksModule.java} | 36 +++--
.../PeriodicalHealthChecksConfigurationTest.java | 127 +++++++++++++++++
.../apache/james/PeriodicalHealthChecksTest.java | 104 ++++++++++++++
.../james/jpa/healthcheck/JPAHealthCheck.java | 10 +-
.../jmap/draft/methods/GetMailboxesMethod.java | 109 +++++++-------
.../jmap/draft/methods/GetMailboxesMethodTest.java | 4 +
.../rabbitmq/FixingGhostMailboxTest.java | 5 +-
.../RabbitMQEventDeadLettersIntegrationTest.java | 87 ++++++++++--
.../james/webadmin/routes/HealthCheckRoutes.java | 8 ++
src/adr/0022-cassandra-message-inconsistency.md | 2 +-
src/site/site.xml | 1 +
.../config-healthcheck.xml} | 25 ++--
upgrade-instructions.md | 10 +-
75 files changed, 2038 insertions(+), 680 deletions(-)
copy json/src/test/java/org/apache/james/dto/BaseType.java =>
backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/configuration/InjectionNames.java
(90%)
create mode 100644
backends-common/cassandra/src/main/java/org/apache/james/backends/cassandra/init/configuration/KeyspaceConfiguration.java
copy
mailbox/api/src/main/java/org/apache/james/mailbox/model/MessageIdDto.java =>
backends-common/rabbitmq/src/main/java/org/apache/james/backends/rabbitmq/RabbitMQServerVersion.java
(58%)
create mode 100644
backends-common/rabbitmq/src/test/java/org/apache/james/backends/rabbitmq/RabbitMQServerVersionTest.java
copy
dockerfiles/{packaging/guice/cassandra/package/etc/james/templates/webadmin.properties
=> run/guice/cassandra-ldap/destination/conf/healthcheck.properties} (68%)
copy
dockerfiles/{packaging/guice/cassandra/package/etc/james/templates/webadmin.properties
=> run/guice/cassandra-rabbitmq-ldap/destination/conf/healthcheck.properties}
(68%)
copy
dockerfiles/{packaging/guice/cassandra/package/etc/james/templates/webadmin.properties
=> run/guice/cassandra-rabbitmq/destination/conf/healthcheck.properties} (68%)
copy
dockerfiles/{packaging/guice/cassandra/package/etc/james/templates/webadmin.properties
=> run/guice/cassandra/destination/conf/healthcheck.properties} (68%)
copy
dockerfiles/{packaging/guice/cassandra/package/etc/james/templates/webadmin.properties
=> run/guice/jpa-smtp/destination/conf/healthcheck.properties} (68%)
copy
dockerfiles/{packaging/guice/cassandra/package/etc/james/templates/webadmin.properties
=> run/guice/jpa/destination/conf/healthcheck.properties} (68%)
copy
dockerfiles/{packaging/guice/cassandra/package/etc/james/templates/webadmin.properties
=> run/guice/memory/destination/conf/healthcheck.properties} (68%)
create mode 100644
server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/CassandraCacheSessionModule.java
create mode 100644
server/container/guice/cassandra-guice/src/main/java/org/apache/james/modules/mailbox/KeyspacesConfiguration.java
create mode 100644
server/container/guice/cassandra-guice/src/test/java/org/apache/james/CacheSessionTest.java
create mode 100644
server/container/guice/cassandra-guice/src/test/java/org/apache/james/KeyspaceCreationTest.java
copy
server/{mailet/mailets/src/test/java/org/apache/james/transport/matchers/dlp/DlpDomainRulesTest.java
=>
container/guice/cassandra-guice/src/test/java/org/apache/james/modules/mailbox/KeyspacesConfigurationTest.java}
(60%)
create mode 100644
server/container/guice/guice-common/src/main/java/org/apache/james/PeriodicalHealthChecks.java
create mode 100644
server/container/guice/guice-common/src/main/java/org/apache/james/PeriodicalHealthChecksConfiguration.java
copy
server/container/guice/{blob-export-guice/src/main/java/org/apache/james/modules/LocalFileBlobExportMechanismModule.java
=>
guice-common/src/main/java/org/apache/james/modules/PeriodicalHealthChecksModule.java}
(61%)
create mode 100644
server/container/guice/guice-common/src/test/java/org/apache/james/PeriodicalHealthChecksConfigurationTest.java
create mode 100644
server/container/guice/guice-common/src/test/java/org/apache/james/PeriodicalHealthChecksTest.java
copy src/site/xdoc/{mailbox/mailbox-cassandra.xml =>
server/config-healthcheck.xml} (53%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]