| commit | 819d61dfb8a9469495bd597f23ff91e4a20f2178 | [log] [tgz] |
|---|---|---|
| author | Madan Jampani <madan@onlab.us> | Mon Jul 25 20:29:43 2016 -0700 |
| committer | Madan Jampani <madan@onlab.us> | Thu Jul 28 04:22:28 2016 +0000 |
| tree | c7514808d9141d101d04573bc2811bf9b2263cbc | |
| parent | 956610d2876b15566fd2b84e74421a1c77f35e23 [diff] [blame] |
Work queue improvements - Fixed logic to ensure only session to which task is currently assigned can complete it - Support destroy method to reset work queue state - Removed deprecated DistributedQueue primitive Change-Id: I4e1d5be4eb142115130acf15ff34035cb9319a1a
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDistributedWorkQueue.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDistributedWorkQueue.java index 2f604d3..9ce11bf 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDistributedWorkQueue.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/DefaultDistributedWorkQueue.java
@@ -30,6 +30,11 @@ } @Override + public String name() { + return backingQueue.name(); + } + + @Override public CompletableFuture<Void> addMultiple(Collection<E> items) { return backingQueue.addMultiple(items.stream() .map(serializer::encode)