void () { ApplicationManager.getApplication().assertReadAccessAllowed(); LOG.assertTrue(!breakpointsInitialized); breakpointsInitialized = true; disableSlaveBreakpoints(); processAllBreakpoints(true, false); if (myBreakpointListenerDisposable == null) { myBreakpointListenerDisposable = Disposer.newDisposable(); Disposer.register(myProject, myBreakpointListenerDisposable); MessageBusConnection busConnection = myProject.getMessageBus().connect(myBreakpointListenerDisposable); busConnection.subscribe(XBreakpointListener.TOPIC, new MyBreakpointListener()); busConnection.subscribe(XDependentBreakpointListener.TOPIC, new MyDependentBreakpointListener()); } }