ProjectTopics.MODULES broadcast direction changed to NONE — mostly all clients alread...
authorVladimir Krivosheev <vladimir.krivosheev@jetbrains.com>
Thu, 18 Jun 2020 08:04:39 +0000 (10:04 +0200)
committerintellij-monorepo-bot <intellij-monorepo-bot-no-reply@jetbrains.com>
Thu, 18 Jun 2020 08:35:57 +0000 (11:35 +0300)
GitOrigin-RevId: ffe95fda1dfb04520d7f8181aed5b50d3529940a

platform/configuration-store-impl/testSrc/ModuleStoreRenameTest.kt
platform/execution-impl/src/com/intellij/execution/impl/ModuleRunConfigurationManager.java
platform/lang-impl/src/com/intellij/openapi/roots/impl/storage/ClasspathStorage.java
platform/projectModel-api/src/com/intellij/ProjectTopics.java

index f97770785fd0cf7d29ca9588cfa0dc0e7e497ca8..5431376dcd4c8b87cc19bf64ea891fc07db74b4d 100644 (file)
@@ -70,7 +70,7 @@ internal class ModuleStoreRenameTest {
           ModuleRootModificationUtil.addDependency(dependentModule, module)
         }
 
-        module.messageBus.connect().subscribe(ProjectTopics.MODULES, object : ModuleListener {
+        projectRule.project.messageBus.connect(module).subscribe(ProjectTopics.MODULES, object : ModuleListener {
           override fun modulesRenamed(project: Project, modules: MutableList<Module>, oldNameProvider: Function<Module, String>) {
             assertThat(modules).containsOnly(module)
             oldModuleNames.add(oldNameProvider.`fun`(module))
index 62beae57febf2803c029e6f94a603e566285b75e..7946164d623f006855b490d1e06cab957d4f52b8 100644 (file)
@@ -42,7 +42,7 @@ public final class ModuleRunConfigurationManager implements PersistentStateCompo
 
   public ModuleRunConfigurationManager(@NotNull Module module) {
     myModule = module;
-    myModule.getMessageBus().connect().subscribe(ProjectTopics.MODULES, new ModuleListener() {
+    myModule.getProject().getMessageBus().connect(myModule).subscribe(ProjectTopics.MODULES, new ModuleListener() {
       @Override
       public void beforeModuleRemoved(@NotNull Project project, @NotNull Module module) {
         if (myModule.equals(module)) {
index b458532a341802982db8219572c08680407e9603..5350e60129931cbd3971cec9152046db97f6d7a6 100644 (file)
@@ -49,7 +49,7 @@ public final class ClasspathStorage extends StateStorageBase<Boolean> {
 
   private final PathMacroSubstitutor myPathMacroSubstitutor;
 
-  public ClasspathStorage(@NotNull final Module module, @NotNull StateStorageManager storageManager) {
+  public ClasspathStorage(@NotNull Module module, @NotNull StateStorageManager storageManager) {
     String storageType = module.getOptionValue(JpsProjectLoader.CLASSPATH_ATTRIBUTE);
     if (storageType == null) {
       throw new IllegalStateException("Classpath storage requires non-default storage type");
@@ -67,7 +67,8 @@ public final class ClasspathStorage extends StateStorageBase<Boolean> {
       }
 
       myConverter = new MissingClasspathConverter();
-    } else {
+    }
+    else {
       myConverter = provider.createConverter(module);
     }
 
@@ -100,7 +101,7 @@ public final class ClasspathStorage extends StateStorageBase<Boolean> {
       }
     });
 
-    busConnection.subscribe(ProjectTopics.MODULES, new ModuleListener() {
+    module.getProject().getMessageBus().connect(module).subscribe(ProjectTopics.MODULES, new ModuleListener() {
       @Override
       public void modulesRenamed(@NotNull Project project,
                                  @NotNull List<Module> modules,
index 6cb11bbf825c9ecdfe5b701ac3bfb14163c39d0d..d0a6099a238678eae50b3efb3940bd97ea141703 100644 (file)
@@ -16,7 +16,7 @@ public final class ProjectTopics {
    * Modules added or removed from project.
    */
   @Topic.ProjectLevel
-  public static final Topic<ModuleListener> MODULES = new Topic<>(ModuleListener.class);
+  public static final Topic<ModuleListener> MODULES = new Topic<>(ModuleListener.class, Topic.BroadcastDirection.NONE);
 
   private ProjectTopics() {
   }