Examples of com.intellij.util.messages.MessageBusConnection.subscribe()

Class com.intellij.util.messages.MessageBusConnection

Examples of com.intellij.util.messages.MessageBusConnection.subscribe()

com.intellij.util.messages.MessageBusConnection.subscribe()
Subscribes given handler to the target endpoint within the current connection. @param topic target endpoint @param handler target handler to use for incoming messages @param < L> interface for working with the target topic @throws IllegalStateException if there is already registered handler for the target endpoint within the current connection.Note that that previously registered handler is not replaced by the given one then @see MessageBus#syncPublisher(Topic)

      }
    }
    );


    final MessageBusConnection messageBusConnection = project.getMessageBus().connect(usageView);
    messageBusConnection.subscribe(UsageFilteringRuleProvider.RULES_CHANGED, new Runnable() {
      @Override
      public void run() {
        pingEDT.ping();
      }
    });

View Full Code Here

        rebuildPopup(usageView, copy, nodes, table, popup, presentation, popupPosition, !processIcon.isDisposed());
      }
    });


    final MessageBusConnection messageBusConnection = project.getMessageBus().connect(usageView);
    messageBusConnection.subscribe(UsageFilteringRuleProvider.RULES_CHANGED, new Runnable() {
      @Override
      public void run() {
        pingEDT.ping();
      }
    });

View Full Code Here

        return connection;
    }
    
    public static <T> void subscribe(Project project, Topic<T> topic, T handler) {
        MessageBusConnection messageBusConnection = connect(project, handler);
        messageBusConnection.subscribe(topic, handler);
    }


    public static <T> void subscribe(Topic<T> topic, T handler) {
        MessageBusConnection messageBusConnection = connect(handler);
        messageBusConnection.subscribe(topic, handler);

View Full Code Here

        messageBusConnection.subscribe(topic, handler);
    }


    public static <T> void subscribe(Topic<T> topic, T handler) {
        MessageBusConnection messageBusConnection = connect(handler);
        messageBusConnection.subscribe(topic, handler);
    }


    public static <T> T notify(Project project, Topic<T> topic) {
        if (project != null) {
            MessageBus messageBus = project.getMessageBus();

View Full Code Here

      }
    });


    // clear caches after modules roots were changed
    final MessageBusConnection connection = project.getMessageBus().connect();
    connection.subscribe(ProjectTopics.PROJECT_ROOTS, new ModuleRootListener() {
      final List<VirtualFile> myPreviousStepDefsProviders = new ArrayList<VirtualFile>();


      public void beforeRootsChange(ModuleRootEvent event) {
        myPreviousStepDefsProviders.clear();

View Full Code Here

  }


  @Override
  public void initComponent() {
    MessageBusConnection appBus = myApplication.getMessageBus().connect(myProject);
    appBus.subscribe(FrameworkDefinitionListener.TOPIC, new MyFrameworkDefinitionListener());


    myProjectSettings.addProjectSettingsListener(this);


    MessageBusConnection projectBus = myProject.getMessageBus().connect(myProject);
    projectBus.subscribe(ProjectTopics.PROJECT_ROOTS, new MyModuleRootListener());

View Full Code Here

    appBus.subscribe(FrameworkDefinitionListener.TOPIC, new MyFrameworkDefinitionListener());


    myProjectSettings.addProjectSettingsListener(this);


    MessageBusConnection projectBus = myProject.getMessageBus().connect(myProject);
    projectBus.subscribe(ProjectTopics.PROJECT_ROOTS, new MyModuleRootListener());
    projectBus.subscribe(ProjectTopics.MODULES, new MyModuleRenameHandler());
  }


  @Override
  public void disposeComponent() {

View Full Code Here


    myProjectSettings.addProjectSettingsListener(this);


    MessageBusConnection projectBus = myProject.getMessageBus().connect(myProject);
    projectBus.subscribe(ProjectTopics.PROJECT_ROOTS, new MyModuleRootListener());
    projectBus.subscribe(ProjectTopics.MODULES, new MyModuleRenameHandler());
  }


  @Override
  public void disposeComponent() {
    myProjectSettings.removeProjectSettingsListener(this);

View Full Code Here


    public OpenEditorTracker startTracking() {
      ProjectManager.getInstance().addProjectManagerListener(new ProjectManagerAdapter() {
        @Override public void projectOpened(final Project project) {
                    MessageBusConnection connection = project.getMessageBus().connect();
                    connection.subscribe(FILE_EDITOR_MANAGER, new FileEditorManagerAdapter() {
                        @Override
                        public void selectionChanged(@NotNull FileEditorManagerEvent event) {
                            VirtualFile virtualFile = event.getNewFile();
                            if (virtualFile == null) return;

View Full Code Here

    myMessageBus = messageBus;
  }


  public void add(@NotNull T listener) {
    final MessageBusConnection connection = myMessageBus.connect();
    connection.subscribe(myTopic, listener);
    myListenerToConnectionMap.put(listener, connection);
  }


  public void add(@NotNull final T listener, @NotNull Disposable parentDisposable) {
    Disposer.register(parentDisposable, new Disposable() {

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.