You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2019/05/07 04:24:29 UTC
[james-project] 01/03: JAMES-2716 expose eventBus in
InMemoryIntegrationResources
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
commit 6d4572c87e7a8c6e20634f9bab5a5084a2d6ba49
Author: Tran Tien Duc <dt...@linagora.com>
AuthorDate: Wed Apr 17 13:55:24 2019 +0700
JAMES-2716 expose eventBus in InMemoryIntegrationResources
To be used later when testing BigMessage Listeners. I have to register
that listener to eventBus
---
.../manager/InMemoryIntegrationResources.java | 23 ++++++++++++++--------
1 file changed, 15 insertions(+), 8 deletions(-)
diff --git a/mailbox/memory/src/test/java/org/apache/james/mailbox/inmemory/manager/InMemoryIntegrationResources.java b/mailbox/memory/src/test/java/org/apache/james/mailbox/inmemory/manager/InMemoryIntegrationResources.java
index d9b36e7..4d03fec 100644
--- a/mailbox/memory/src/test/java/org/apache/james/mailbox/inmemory/manager/InMemoryIntegrationResources.java
+++ b/mailbox/memory/src/test/java/org/apache/james/mailbox/inmemory/manager/InMemoryIntegrationResources.java
@@ -290,7 +290,8 @@ public class InMemoryIntegrationResources implements IntegrationResources<StoreM
InMemoryMailboxSessionMapperFactory mailboxSessionMapperFactory = new InMemoryMailboxSessionMapperFactory();
GroupMembershipResolver groupMembershipResolver = new SimpleGroupMembershipResolver();
- StoreRightManager storeRightManager = new StoreRightManager(mailboxSessionMapperFactory, new UnionMailboxACLResolver(), groupMembershipResolver, eventBus.get());
+ EventBus eventBus = this.eventBus.get();
+ StoreRightManager storeRightManager = new StoreRightManager(mailboxSessionMapperFactory, new UnionMailboxACLResolver(), groupMembershipResolver, eventBus);
StoreMailboxAnnotationManager annotationManager = new StoreMailboxAnnotationManager(mailboxSessionMapperFactory,
storeRightManager, limitAnnotationCount.get(), limitAnnotationSize.get());
@@ -301,7 +302,7 @@ public class InMemoryIntegrationResources implements IntegrationResources<StoreM
DefaultUserQuotaRootResolver quotaRootResolver = new DefaultUserQuotaRootResolver(sessionProvider, mailboxSessionMapperFactory);
InMemoryCurrentQuotaManager currentQuotaManager = new InMemoryCurrentQuotaManager(new CurrentQuotaCalculator(mailboxSessionMapperFactory, quotaRootResolver), sessionProvider);
QuotaManager quotaManager = this.quotaManager.get().apply(new BaseQuotaComponentsStage(maxQuotaManager, currentQuotaManager));
- ListeningCurrentQuotaUpdater listeningCurrentQuotaUpdater = new ListeningCurrentQuotaUpdater(currentQuotaManager, quotaRootResolver, eventBus.get(), quotaManager);
+ ListeningCurrentQuotaUpdater listeningCurrentQuotaUpdater = new ListeningCurrentQuotaUpdater(currentQuotaManager, quotaRootResolver, eventBus, quotaManager);
QuotaComponents quotaComponents = new QuotaComponents(maxQuotaManager, quotaManager, quotaRootResolver, listeningCurrentQuotaUpdater);
MailboxManagerPreInstanciationStage preInstanciationStage = new MailboxManagerPreInstanciationStage(mailboxSessionMapperFactory, sessionProvider);
@@ -313,19 +314,19 @@ public class InMemoryIntegrationResources implements IntegrationResources<StoreM
new JVMMailboxPathLocker(),
messageParser.get(),
new InMemoryMessageId.Factory(),
- eventBus.get(),
+ eventBus,
annotationManager,
storeRightManager,
quotaComponents,
index,
createHooks(preInstanciationStage));
- eventBus.get().register(listeningCurrentQuotaUpdater);
- eventBus.get().register(new MailboxAnnotationListener(mailboxSessionMapperFactory, sessionProvider));
+ eventBus.register(listeningCurrentQuotaUpdater);
+ eventBus.register(new MailboxAnnotationListener(mailboxSessionMapperFactory, sessionProvider));
- listenersToBeRegistered.build().forEach(eventBus.get()::register);
+ listenersToBeRegistered.build().forEach(eventBus::register);
- return new InMemoryIntegrationResources(manager, storeRightManager, new InMemoryMessageId.Factory(), currentQuotaManager, quotaRootResolver, maxQuotaManager, quotaManager, index);
+ return new InMemoryIntegrationResources(manager, storeRightManager, new InMemoryMessageId.Factory(), currentQuotaManager, quotaRootResolver, maxQuotaManager, quotaManager, index, eventBus);
}
private PreDeletionHooks createHooks(MailboxManagerPreInstanciationStage preInstanciationStage) {
@@ -382,8 +383,9 @@ public class InMemoryIntegrationResources implements IntegrationResources<StoreM
private final QuotaManager quotaManager;
private final StoreMessageIdManager storeMessageIdManager;
private final MessageSearchIndex searchIndex;
+ private final EventBus eventBus;
- InMemoryIntegrationResources(InMemoryMailboxManager mailboxManager, StoreRightManager storeRightManager, MessageId.Factory messageIdFactory, InMemoryCurrentQuotaManager currentQuotaManager, DefaultUserQuotaRootResolver defaultUserQuotaRootResolver, InMemoryPerUserMaxQuotaManager maxQuotaManager, QuotaManager quotaManager, MessageSearchIndex searchIndex) {
+ InMemoryIntegrationResources(InMemoryMailboxManager mailboxManager, StoreRightManager storeRightManager, MessageId.Factory messageIdFactory, InMemoryCurrentQuotaManager currentQuotaManager, DefaultUserQuotaRootResolver defaultUserQuotaRootResolver, InMemoryPerUserMaxQuotaManager maxQuotaManager, QuotaManager quotaManager, MessageSearchIndex searchIndex, EventBus eventBus) {
this.mailboxManager = mailboxManager;
this.storeRightManager = storeRightManager;
this.messageIdFactory = messageIdFactory;
@@ -392,6 +394,7 @@ public class InMemoryIntegrationResources implements IntegrationResources<StoreM
this.maxQuotaManager = maxQuotaManager;
this.quotaManager = quotaManager;
this.searchIndex = searchIndex;
+ this.eventBus = eventBus;
this.storeMessageIdManager = new StoreMessageIdManager(
mailboxManager,
@@ -443,4 +446,8 @@ public class InMemoryIntegrationResources implements IntegrationResources<StoreM
public MessageSearchIndex getSearchIndex() {
return searchIndex;
}
+
+ public EventBus getEventBus() {
+ return eventBus;
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org