You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2018/12/30 18:45:54 UTC
[camel] 02/02: CAMEL-12969: Fixed CS
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-2.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit c24ad7c9d308fccd2345055f4ec8032ba1fb38bd
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sun Dec 30 19:00:08 2018 +0100
CAMEL-12969: Fixed CS
---
.../org/apache/camel/core/osgi/OsgiServiceRegistry.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiServiceRegistry.java b/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiServiceRegistry.java
index 8045c95..50822fd 100644
--- a/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiServiceRegistry.java
+++ b/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiServiceRegistry.java
@@ -156,22 +156,22 @@ public class OsgiServiceRegistry extends LifecycleStrategySupport implements Reg
this.serviceReferenceUsageMap.clear();
}
- void drainServiceUsage(ServiceReference<?> serviceReference, AtomicLong serviceUsageCount) {
+ private void drainServiceUsage(ServiceReference<?> serviceReference, AtomicLong serviceUsageCount) {
if (serviceUsageCount != null && serviceReference != null) {
- while(serviceUsageCount.decrementAndGet() >= 0) {
+ while (serviceUsageCount.decrementAndGet() >= 0) {
this.bundleContext.ungetService(serviceReference);
}
}
}
-
- void incrementServiceUsage(ServiceReference<?> sr) {
+
+ private void incrementServiceUsage(ServiceReference<?> sr) {
AtomicLong serviceUsageCount = this.serviceReferenceUsageMap.get(sr);
if (serviceUsageCount != null) {
serviceUsageCount.incrementAndGet();
} else {
- this.serviceReferenceUsageMap.merge(sr, new AtomicLong(1),
- (existingServiceUsageCount, newServiceUsageCount)->{
- existingServiceUsageCount.getAndAdd(newServiceUsageCount.get());
+ this.serviceReferenceUsageMap.merge(sr, new AtomicLong(1),
+ (existingServiceUsageCount, newServiceUsageCount) -> {
+ existingServiceUsageCount.getAndAdd(newServiceUsageCount.get());
return existingServiceUsageCount;
});
}