commit | 6cf60c3f33b5155a8cb51a9cd4d2f60007de92da | [log] [tgz] |
---|---|---|
author | Jordan Halterman <jordan@opennetworking.org> | Wed Aug 15 01:22:51 2018 -0700 |
committer | Jordan Halterman <jordan@opennetworking.org> | Wed Aug 15 17:41:48 2018 +0000 |
tree | a970263954e49147fe1a59a059d6b199dddb5730 | |
parent | 6771f4f49f747c41539331e0484fcda6ea8f1f6d [diff] [blame] |
Convert all Atomix exceptions to ONOS storage exceptions Change-Id: If4ba6b4fa41643fc3d9a9f2d84dc68fd6399a352
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixAtomicIdGenerator.java b/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixAtomicIdGenerator.java index 97d0268..e762511 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixAtomicIdGenerator.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/atomix/primitives/impl/AtomixAtomicIdGenerator.java
@@ -19,6 +19,8 @@ import org.onosproject.store.service.AsyncAtomicIdGenerator; +import static org.onosproject.store.atomix.primitives.impl.AtomixFutures.adaptFuture; + /** * Atomix atomic ID generator. */ @@ -36,6 +38,6 @@ @Override public CompletableFuture<Long> nextId() { - return atomixIdGenerator.nextId(); + return adaptFuture(atomixIdGenerator.nextId()); } }