X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsamples%2Fclustering-test-app%2Fprovider%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fclustering%2Fit%2Flistener%2FPeopleCarListener.java;h=5dee90db877e57368ec12dee7ff54a2d245e2bf0;hp=bbaf6becf4b10ceef502005578f1f4311d9ca2cb;hb=f6d4d8759fcce4d35f38f5a5a056acf1d3e0b4b2;hpb=df894b365aa4f958a031cf453a028c947d5f7f8d diff --git a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/listener/PeopleCarListener.java b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/listener/PeopleCarListener.java index bbaf6becf4..5dee90db87 100644 --- a/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/listener/PeopleCarListener.java +++ b/opendaylight/md-sal/samples/clustering-test-app/provider/src/main/java/org/opendaylight/controller/clustering/it/listener/PeopleCarListener.java @@ -26,7 +26,7 @@ import org.slf4j.LoggerFactory; public class PeopleCarListener implements CarPurchaseListener { - private static final Logger log = LoggerFactory.getLogger(PeopleCarListener.class); + private static final Logger LOG = LoggerFactory.getLogger(PeopleCarListener.class); private DataBroker dataProvider; @@ -46,24 +46,24 @@ public class PeopleCarListener implements CarPurchaseListener { carPersonBuilder.setKey(key); final CarPerson carPerson = carPersonBuilder.build(); - log.info("Car bought, adding car-person entry: [{}]", carPerson); + LOG.info("Car bought, adding car-person entry: [{}]", carPerson); InstanceIdentifier carPersonIId = InstanceIdentifier.builder(CarPeople.class).child(CarPerson.class, carPerson.getKey()).build(); WriteTransaction tx = dataProvider.newWriteOnlyTransaction(); - tx.put(LogicalDatastoreType.CONFIGURATION, carPersonIId, carPerson); + tx.put(LogicalDatastoreType.CONFIGURATION, carPersonIId, carPerson, true); Futures.addCallback(tx.submit(), new FutureCallback() { @Override public void onSuccess(final Void result) { - log.info("Successfully added car-person entry: [{}]", carPerson); + LOG.info("Successfully added car-person entry: [{}]", carPerson); } @Override public void onFailure(final Throwable t) { - log.error(String.format("Failed to add car-person entry: [%s]", carPerson), t); + LOG.error(String.format("Failed to add car-person entry: [%s]", carPerson), t); } });