MDSAL DS acces - standalone bundle.
[lispflowmapping.git] / mappingservice / dsbackend / src / main / java / org / opendaylight / lispflowmapping / dsbackend / DataStoreBackEnd.java
similarity index 98%
rename from mappingservice/implementation/src/main/java/org/opendaylight/lispflowmapping/implementation/mdsal/DataStoreBackEnd.java
rename to mappingservice/dsbackend/src/main/java/org/opendaylight/lispflowmapping/dsbackend/DataStoreBackEnd.java
index aee385ac0423981bdaae8adb261256190434a68e..9d2d2a351f4255eb568d0c64269c15c16c30ff16 100644 (file)
@@ -5,7 +5,7 @@
  * 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.lispflowmapping.implementation.mdsal;
+package org.opendaylight.lispflowmapping.dsbackend;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -19,7 +19,6 @@ import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
 import org.opendaylight.controller.md.sal.common.api.data.TransactionChain;
 import org.opendaylight.controller.md.sal.common.api.data.TransactionChainListener;
-import org.opendaylight.lispflowmapping.implementation.util.InstanceIdentifierUtil;
 import org.opendaylight.lispflowmapping.lisp.util.LispAddressStringifier;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.XtrId;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.mappingservice.rev150906.MappingDatabase;
@@ -54,6 +53,7 @@ public class DataStoreBackEnd implements TransactionChainListener {
         this.txChain = broker.createTransactionChain(this);
     }
 
+
     public void addAuthenticationKey(AuthenticationKey authenticationKey) {
         if (LOG.isDebugEnabled()) {
             LOG.debug("MD-SAL: Adding authentication key '{}' for {}",
@@ -224,10 +224,10 @@ public class DataStoreBackEnd implements TransactionChainListener {
         WriteTransaction writeTx = txChain.newWriteOnlyTransaction();
         writeTx.put(logicalDatastoreType, addIID, data, true);
         Futures.addCallback(writeTx.submit(), new FutureCallback<Void>() {
-            @Override
+
             public void onSuccess(Void result) {
             }
-            @Override
+
             public void onFailure(Throwable t) {
                 LOG.error("Transaction failed:", t);
             }
@@ -258,24 +258,22 @@ public class DataStoreBackEnd implements TransactionChainListener {
         WriteTransaction writeTx = txChain.newWriteOnlyTransaction();
         writeTx.delete(logicalDatastoreType, deleteIID);
         Futures.addCallback(writeTx.submit(), new FutureCallback<Void>() {
-            @Override
+
             public void onSuccess(Void result) {
             }
-            @Override
+
             public void onFailure(Throwable t) {
                 LOG.error("Transaction failed:", t);
             }
         });
     }
 
-    @Override
     public void onTransactionChainFailed(TransactionChain<?, ?> chain, AsyncTransaction<?, ?> transaction,
             Throwable cause) {
         LOG.error("Broken chain {} in DataStoreBackEnd, transaction {}, cause {}", chain, transaction.getIdentifier(),
                 cause);
     }
 
-    @Override
     public void onTransactionChainSuccessful(TransactionChain<?, ?> chain) {
         LOG.info("DataStoreBackEnd closed successfully, chain {}", chain);
     }