commit | 35708a94b7fcc2beb5addad49f9f3a3185fb08a3 | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan@onlab.us> | Wed Jul 06 10:48:19 2016 -0700 |
committer | Gerrit Code Review <gerrit@onlab.us> | Tue Jul 12 02:00:47 2016 +0000 |
tree | 61bb97620c653df11c812e94eeab058436c65e34 | |
parent | 54c5e238e67abb66683430a04b8394db388dc837 [diff] [blame] |
Distributed work queue primitive Change-Id: Ia8e531e6611ec502399edec376ccc00522e47994
diff --git a/core/api/src/main/java/org/onosproject/store/service/StorageService.java b/core/api/src/main/java/org/onosproject/store/service/StorageService.java index e10c3d0..f342bdd 100644 --- a/core/api/src/main/java/org/onosproject/store/service/StorageService.java +++ b/core/api/src/main/java/org/onosproject/store/service/StorageService.java
@@ -107,4 +107,13 @@ default AtomicCounter getAtomicCounter(String name) { return getAsyncAtomicCounter(name).asAtomicCounter(); } + + /** + * Returns an instance of {@code WorkQueue} with specified name. + * @param name work queue name + * @param serializer serializer + * + * @return WorkQueue instance + */ + <E> WorkQueue<E> getWorkQueue(String name, Serializer serializer); }