public BindServiceImpl addingService()

in cdi-extender/src/main/java/org/apache/aries/cdi/container/internal/model/BindServiceImpl.java [54:86]

30 lines of code
4 McCabe index (conditional complexity)


	public BindServiceImpl<T> addingService(ServiceReference<T> reference) {
		if (_enqueue.get()) {
			_queue.add(reference);
			return this;
		}

		BundleContext bundleContext = _containerState.bundleContext();
		service = bundleContext.getService(reference);
		Map<String, Object> map = Maps.of(reference.getProperties());

		onAdding.ifPresent(
			c -> {
				try {
					c.accept(service);
				}
				catch (Throwable t) {
					_log.error(l -> l.error("CCR error in {}", this, t));
				}
			}
		);
		onAddingBi.ifPresent(
			c -> {
				try {
					c.accept(service, map);
				}
				catch (Throwable t) {
					_log.error(l -> l.error("CCR error in {}", this, t));
				}
			}
		);

		return this;
	}