From d4679c9a3ccb6449dba402747c402d0e92c2e0dc Mon Sep 17 00:00:00 2001 From: Konrad Windszus Date: Fri, 21 Jun 2024 16:15:53 +0200 Subject: [PATCH] Add OSGi condition which is satisfied once the default Ehcache services are registered This allows to defer starting of custom OSGi DS component which rely on the EhcacheManager in their activate() method until the Ehcache services are registered This closes #3232 --- docs/src/docs/asciidoc/user/osgi.adoc | 2 + ehcache-impl/build.gradle | 2 + .../impl/osgi/EhcacheReadyCondition.java | 67 +++++++++++++++++++ 3 files changed, 71 insertions(+) create mode 100644 ehcache-impl/src/main/java/org/ehcache/impl/osgi/EhcacheReadyCondition.java diff --git a/docs/src/docs/asciidoc/user/osgi.adoc b/docs/src/docs/asciidoc/user/osgi.adoc index 2f22bd0e40..01bf50bd14 100644 --- a/docs/src/docs/asciidoc/user/osgi.adoc +++ b/docs/src/docs/asciidoc/user/osgi.adoc @@ -53,6 +53,8 @@ Additional features can then be added by including one or more of: * `org.ehcache:ehcache-clustered` * `org.ehcache:ehcache-transactions` +In order to defer starting OSGi DS components which leverage `org.ehcache.core.CacheManager` (for example via `CacheManagerBuilder`) until all relevant services for Ehcache are available one can leverage the https://docs.osgi.org/specification/osgi.core/8.0.0/service.condition.html[OSGi condition] with id `ehcache`. + === Reverting to JDK Service Lookup If the `org.ehcache.core.osgi` property is set to `"false"` as either a framework or system property then Ehcache will diff --git a/ehcache-impl/build.gradle b/ehcache-impl/build.gradle index 94674d88ef..e575ff226e 100644 --- a/ehcache-impl/build.gradle +++ b/ehcache-impl/build.gradle @@ -54,6 +54,8 @@ dependencies { implementation group: 'org.ehcache', name: 'sizeof', version: parent.sizeofVersion implementation group: 'org.terracotta', name: 'terracotta-utilities-tools', version: parent.terracottaUtilitiesVersion compileOnly 'org.osgi:org.osgi.service.component.annotations:1.3.0' + compileOnly 'org.osgi:org.osgi.service.component:1.3.0' + implementation 'org.osgi:org.osgi.service.condition:1.0.0' testImplementation project(':core-spi-test') testImplementation 'org.ow2.asm:asm:6.2' testImplementation 'org.ow2.asm:asm-commons:6.2' diff --git a/ehcache-impl/src/main/java/org/ehcache/impl/osgi/EhcacheReadyCondition.java b/ehcache-impl/src/main/java/org/ehcache/impl/osgi/EhcacheReadyCondition.java new file mode 100644 index 0000000000..12fa8b1978 --- /dev/null +++ b/ehcache-impl/src/main/java/org/ehcache/impl/osgi/EhcacheReadyCondition.java @@ -0,0 +1,67 @@ +/* + * Copyright Terracotta, Inc. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.ehcache.impl.osgi; + +import org.ehcache.core.EhcacheManager; +import org.ehcache.core.events.CacheEventDispatcherFactory; +import org.ehcache.core.events.CacheEventListenerProvider; +import org.ehcache.core.spi.service.ServiceFactory; +import org.ehcache.core.spi.store.Store; +import org.ehcache.impl.internal.spi.resilience.DefaultResilienceStrategyProvider; +import org.ehcache.impl.internal.store.tiering.TieredStore; +import org.ehcache.impl.internal.store.tiering.TieredStoreProviderFactory; +import org.ehcache.spi.loaderwriter.CacheLoaderWriterProvider; +import org.ehcache.spi.loaderwriter.WriteBehindProvider; +import org.ehcache.spi.resilience.ResilienceStrategyProvider; +import org.osgi.service.component.ComponentConstants; +import org.osgi.service.component.annotations.Component; +import org.osgi.service.component.annotations.Reference; +import org.osgi.service.condition.Condition; + +/** + * The condition is satisfied once all default {@link ServiceFactory} objects mentioned in {@link EhcacheManager} are registered. + * Those are + *
    + *
  1. {@link Store.Provider} provided through DS component {@link TieredStoreProviderFactory}
    2. + *
  2. {@link CacheLoaderWriterProvider} provided through DS component {@link DefaultCacheLoaderWriterProviderFactory}
    3. + *
  3. {@link WriteBehindProvider} provided through DS component {@link WriteBehindProviderFactory}
    4. + *
  4. {@link CacheEventDispatcherFactory} provided through DS component {@link CacheEventNotificationListenerServiceProviderFactory}
    5. + *
  5. {@link CacheEventListenerProvider} provided through DS component {@link DefaultCacheEventListenerProviderFactory}
    6. + *
  6. {@link ResilienceStrategyProvider} provided through DS component {@link DefaultResilienceStrategyProvider}
    7. + *
+ * Because those services are not provided directly but through {@link ServiceFactory} this condition references directly the responsible default factories (via their component name) + */ +@Component(property = Condition.CONDITION_ID + "=ehcache") +public class EhcacheReadyCondition implements Condition { + + @Reference(target = "("+ComponentConstants.COMPONENT_NAME+"=org.ehcache.impl.internal.store.tiering.TieredStoreProviderFactory)") + private ServiceFactory storeProviderFactory; + + @Reference(target = "("+ComponentConstants.COMPONENT_NAME+"=org.ehcache.impl.internal.spi.loaderwriter.DefaultCacheLoaderWriterProviderFactory)") + private ServiceFactory cacheLoaderWriterProviderFactory; + + @Reference(target = "("+ComponentConstants.COMPONENT_NAME+"=org.ehcache.impl.internal.loaderwriter.writebehind.WriteBehindProviderFactory)") + private ServiceFactory writeBehindProviderFactory; + + @Reference(target = "("+ComponentConstants.COMPONENT_NAME+"=org.ehcache.impl.internal.events.CacheEventNotificationListenerServiceProviderFactory)") + private ServiceFactory cacheEventNotificationListenerServiceProviderFactory; + + @Reference(target = "("+ComponentConstants.COMPONENT_NAME+"=org.ehcache.impl.internal.spi.event.DefaultCacheEventListenerProviderFactory)") + private ServiceFactory cacheEventListenerProviderFactory; + + @Reference(target = "("+ComponentConstants.COMPONENT_NAME+"=org.ehcache.impl.internal.spi.resilience.DefaultResilienceStrategyProviderFactory)") + private ServiceFactory resilienceStrategyProviderFactory; +}