commit 35a02eaa85ac8ebf813e017e4262ff9651183191
author Jordan Halterman <jordan@opennetworking.org> Wed Aug 22 11:57:32 2018 -0700
committer Thomas Vachuska <tom@opennetworking.org> Tue Aug 28 19:28:14 2018 +0000
tree 11e73c3337483beb408927bb7ad09278af0a30fd
parent 9281593e8bc6c0f7875c6192bf2551ab99fa10a5

Implement destroy() method for certain primitives to preserve backwards compatibility

Change-Id: I64e5790d531bf538bbfd886419362b14967331e6

core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixWorkQueue.java

diff --git a/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixWorkQueue.java b/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixWorkQueue.java
index 9125b4d..89ffd4c 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixWorkQueue.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixWorkQueue.java
@@ -80,4 +80,9 @@
                 .withTotalPending(stats.totalPending())
                 .build());
     }
+
+    @Override
+    public CompletableFuture<Void> destroy() {
+        return adaptFuture(atomixWorkQueue.delete());
+    }
 }