import org.opendaylight.controller.sample.kitchen.api.EggsType; //导入依赖的package包/类
@Test
public void testToaster() throws Exception {
    MBeanServer platformMBeanServer = ManagementFactory.getPlatformMBeanServer();
    ObjectName providerOn = new ObjectName("org.opendaylight.controller:name=OpendaylightToaster,type=toaster-provider");

    long toastsMade = (long) platformMBeanServer.getAttribute(providerOn, "ToastsMade");
    assertEquals(0, toastsMade);

    boolean success = true;

    // Make toasts using OSGi service
    success &= kitchenService.makeBreakfast( EggsType.SCRAMBLED, HashBrown.class, 4).get().isSuccessful();
    success &= kitchenService.makeBreakfast( EggsType.POACHED, WhiteBread.class, 8 ).get().isSuccessful();

    assertTrue("Not all breakfasts succeeded", success);

    // Verify toasts made count on provider via JMX/config-subsystem
    toastsMade = (long) platformMBeanServer.getAttribute(providerOn, "ToastsMade");
    assertEquals(2, toastsMade);
}
 

import org.opendaylight.controller.sample.kitchen.api.EggsType; //导入依赖的package包/类
@Override
public Boolean makeScrambledWithWheat() {
    try {
        // This call has to block since we must return a result to the JMX client.
        RpcResult<Void> result = makeBreakfast(EggsType.SCRAMBLED, WheatBread.class, 2).get();
        if (result.isSuccessful()) {
            LOG.info("makeBreakfast succeeded");
        } else {
            LOG.warn("makeBreakfast failed: " + result.getErrors());
        }

        return result.isSuccessful();

    } catch (InterruptedException | ExecutionException e) {
        LOG.warn("An error occurred while maing breakfast: " + e);
    }

    return Boolean.FALSE;
}
 

import org.opendaylight.controller.sample.kitchen.api.EggsType; //导入依赖的package包/类
@Override
public Future<RpcResult<Void>> makeBreakfast(EggsType eggsType, Class<? extends ToastType> toastType,
        int toastDoneness) {
    // Call makeToast and use JdkFutureAdapters to convert the Future to a ListenableFuture, The
    // OpendaylightToaster impl already returns a ListenableFuture so the conversion is actually a no-op.

    ListenableFuture<RpcResult<Void>> makeToastFuture = JdkFutureAdapters
            .listenInPoolThread(makeToast(toastType, toastDoneness), executor);

    ListenableFuture<RpcResult<Void>> makeEggsFuture = makeEggs(eggsType);

    // Combine the 2 ListenableFutures into 1 containing a list RpcResults.

    ListenableFuture<List<RpcResult<Void>>> combinedFutures = Futures
            .allAsList(ImmutableList.of(makeToastFuture, makeEggsFuture));

    // Then transform the RpcResults into 1.

    return Futures.transformAsync(combinedFutures, results -> {
        boolean atLeastOneSucceeded = false;
        Builder<RpcError> errorList = ImmutableList.builder();
        for (RpcResult<Void> result : results) {
            if (result.isSuccessful()) {
                atLeastOneSucceeded = true;
            }

            if (result.getErrors() != null) {
                errorList.addAll(result.getErrors());
            }
        }

        return Futures.immediateFuture(RpcResultBuilder.<Void>status(atLeastOneSucceeded)
                .withRpcErrors(errorList.build()).build());
    });
}
 

import org.opendaylight.controller.sample.kitchen.api.EggsType; //导入依赖的package包/类
private ListenableFuture<RpcResult<Void>> makeEggs(EggsType eggsType) {
    return executor.submit(() -> RpcResultBuilder.<Void>success().build());
}