X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=test%2Ftools%2Fodl-mdsal-clustering-tests%2Fclustering-test-app%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fit%2Fprovider%2FPurchaseCarProvider.java;fp=test%2Ftools%2Fodl-mdsal-clustering-tests%2Fclustering-test-app%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fit%2Fprovider%2FPurchaseCarProvider.java;h=0000000000000000000000000000000000000000;hb=59e81c38620fa1b61e15771191e35771450b9499;hp=74a0aa68ed91dcac50dbb3714421ffd77f70efe8;hpb=072f6e3a8d1bdf8f4c663843589c22d93ba07791;p=integration%2Ftest.git diff --git a/test/tools/odl-mdsal-clustering-tests/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/PurchaseCarProvider.java b/test/tools/odl-mdsal-clustering-tests/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/PurchaseCarProvider.java deleted file mode 100644 index 74a0aa68ed..0000000000 --- a/test/tools/odl-mdsal-clustering-tests/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/provider/PurchaseCarProvider.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ - -package org.opendaylight.controller.clustering.it.provider; - -import com.google.common.util.concurrent.SettableFuture; -import org.opendaylight.controller.sal.binding.api.NotificationProviderService; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.sal.clustering.it.car.purchase.rev140818.BuyCarInput; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.sal.clustering.it.car.purchase.rev140818.CarBoughtBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.sal.clustering.it.car.purchase.rev140818.CarPurchaseService; -import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.common.RpcResultBuilder; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.concurrent.Future; - - -public class PurchaseCarProvider implements CarPurchaseService, AutoCloseable{ - - private static final Logger log = LoggerFactory.getLogger(PurchaseCarProvider.class); - - private NotificationProviderService notificationProvider; - - - public void setNotificationProvider(final NotificationProviderService salService) { - this.notificationProvider = salService; - } - - - @Override - public Future> buyCar(BuyCarInput input) { - log.info("Routed RPC buyCar : generating notification for buying car [{}]", input); - SettableFuture> futureResult = SettableFuture.create(); - CarBoughtBuilder carBoughtBuilder = new CarBoughtBuilder(); - carBoughtBuilder.setCarId(input.getCarId()); - carBoughtBuilder.setPersonId(input.getPersonId()); - notificationProvider.publish(carBoughtBuilder.build()); - futureResult.set(RpcResultBuilder.success().build()); - return futureResult; - } - - @Override - public void close() throws Exception { - - } -}