void (@NotNull MessageBusConnection busConnection) { busConnection.subscribe(XBreakpointListener.TOPIC, new XBreakpointListener<>() { @Override public void breakpointAdded(@NotNull XBreakpoint<?> xBreakpoint) { Breakpoint<?> breakpoint = getJavaBreakpoint(xBreakpoint); if (breakpoint != null) { addBreakpoint(breakpoint); JavaBreakpointsUsageCollector.reportNewBreakpoint(breakpoint, xBreakpoint.getType()); } } @Override public void breakpointChanged(@NotNull XBreakpoint xBreakpoint) { Breakpoint<?> breakpoint = getJavaBreakpoint(xBreakpoint); if (breakpoint != null) { fireBreakpointChanged(breakpoint); } } }); }