examples/bundles/com.mycorp.examples.timeservice.consumer.ds.async/src/com/mycorp/examples/timeservice/consumer/ds/async/TimeServiceComponentAsync.java

/****************************************************************************
 * Copyright (c) 2014 Composent, Inc.
 *
 * This program and the accompanying materials are made
 * available under the terms of the Eclipse Public License 2.0
 * which is available at https://www.eclipse.org/legal/epl-2.0/
 *
 * Contributors: Scott Lewis - initial API and implementation
 *
 * SPDX-License-Identifier: EPL-2.0
 *****************************************************************************/
package com.mycorp.examples.timeservice.consumer.ds.async;

import java.util.concurrent.CompletableFuture;

import org.osgi.service.component.annotations.Component;
import org.osgi.service.component.annotations.Reference;
import org.osgi.service.component.annotations.ReferenceCardinality;
import org.osgi.service.component.annotations.ReferencePolicy;

import com.mycorp.examples.timeservice.ITimeServiceAsync;

@Component(immediate=true)
public class TimeServiceComponentAsync {

	@Reference(cardinality=ReferenceCardinality.AT_LEAST_ONE,policy=ReferencePolicy.DYNAMIC)
	void bindTimeService(ITimeServiceAsync timeService) {
		System.out.println("Discovered ITimeServiceAsync via DS");
		// Get the CompletableFuture...no blocking here
		CompletableFuture<Long> cf = timeService.getCurrentTimeAsync();
		// print out time when done...no blocking!
		cf.whenComplete((time, exception) -> {
			if (exception != null)
				exception.printStackTrace();
			else
				System.out.println("Remote time is: " + time);
		});
	}
	
	void unbindTimeService(ITimeServiceAsync timeService) {
		System.out.println("Undiscovered ITimeServiceAsync via DS");
	}
}