import java.util.concurrent.locks.ReentrantLock;

@ServiceScope(Scope.CrossBuildSession.class)
public class BuildOperationNotificationBridge implements BuildOperationNotificationListenerRegistrar {

    private static final Logger LOGGER = LoggerFactory.getLogger(BuildOperationNotificationBridge.class);

    private final BuildOperationListenerManager buildOperationListenerManager;
    private final ListenerManager listenerManager;

        return buildOperationNotificationBridge.getValve();
    }

    }

    void register(BuildOperationNotificationListener listener) {
        getOrCreateBridge().register(listener)
    }

    BuildOperationNotificationBridge getOrCreateBridge() {
        if (bridgeInstance == null) {
            bridgeInstance = new BuildOperationNotificationBridge(buildOperationListenerManager, listenerManager)
        } else {
            bridgeInstance
        }
    }