commit | 69fec910d56adc086770f30ec87166457eb533c3 | [log] [tgz] |
---|---|---|
author | poorna <poorna@apache.org> | Wed Apr 25 17:15:48 2018 -0700 |
committer | poorna <poorna@apache.org> | Tue May 01 16:46:44 2018 -0700 |
tree | 5599b9c72d2b8a74d7c93ad77088ab609a84fb64 | |
parent | 305b0a1ff1d17791378c1a902f6f60eda74d601e [diff] |
TEPHRA-267 Save the service reference in ReferenceCountedSupplier only if startup is successful This closes #73 Signed-off-by: poorna <poorna@apache.org>
diff --git a/tephra-core/src/main/java/org/apache/tephra/coprocessor/ReferenceCountedSupplier.java b/tephra-core/src/main/java/org/apache/tephra/coprocessor/ReferenceCountedSupplier.java index c929d29..876767a 100644 --- a/tephra-core/src/main/java/org/apache/tephra/coprocessor/ReferenceCountedSupplier.java +++ b/tephra-core/src/main/java/org/apache/tephra/coprocessor/ReferenceCountedSupplier.java
@@ -53,8 +53,8 @@ // Instance has not been instantiated T serviceInstance = instanceSupplier.get(); - instance.set(serviceInstance); serviceInstance.startAndWait(); + instance.set(serviceInstance); } int newCount = refCount.incrementAndGet(); if (LOG.isDebugEnabled()) {