james-server-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From btell...@apache.org
Subject [james-project] 01/03: JAMES-2716 expose eventBus in InMemoryIntegrationResources
Date Tue, 07 May 2019 04:24:29 GMT
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 <dtran@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


Mime
View raw message