Move cache provider into proper package. (#447)
The cache provider modules source files were previously packaged under the `spring.pulsar.core` name. This moves them to a package name that is specific to their module name. The motivation of the change is to preemptively reduce confusion w/ the Java module system.
This commit is contained in:
@@ -14,12 +14,14 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.pulsar.core;
|
||||
package org.springframework.pulsar.cache.provider.caffeine;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.function.BiConsumer;
|
||||
import java.util.function.Function;
|
||||
|
||||
import org.springframework.pulsar.cache.provider.CacheProvider;
|
||||
|
||||
import com.github.benmanes.caffeine.cache.Cache;
|
||||
|
||||
/**
|
||||
@@ -14,10 +14,13 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.pulsar.core;
|
||||
package org.springframework.pulsar.cache.provider.caffeine;
|
||||
|
||||
import java.time.Duration;
|
||||
|
||||
import org.springframework.pulsar.cache.provider.CacheProvider;
|
||||
import org.springframework.pulsar.cache.provider.CacheProviderFactory;
|
||||
|
||||
import com.github.benmanes.caffeine.cache.Cache;
|
||||
import com.github.benmanes.caffeine.cache.Caffeine;
|
||||
import com.github.benmanes.caffeine.cache.RemovalListener;
|
||||
@@ -0,0 +1 @@
|
||||
org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProviderFactory
|
||||
@@ -1 +0,0 @@
|
||||
org.springframework.pulsar.core.CaffeineCacheProviderFactory
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.pulsar.core;
|
||||
package org.springframework.pulsar.cache.provider;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.function.BiConsumer;
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.pulsar.core;
|
||||
package org.springframework.pulsar.cache.provider;
|
||||
|
||||
import java.time.Duration;
|
||||
import java.util.ServiceLoader;
|
||||
@@ -14,7 +14,7 @@
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package org.springframework.pulsar.core;
|
||||
package org.springframework.pulsar.cache.provider;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
|
||||
@@ -0,0 +1 @@
|
||||
org.springframework.pulsar.cache.provider.CacheProviderFactoryTests$TestCacheProviderFactory
|
||||
@@ -1 +0,0 @@
|
||||
org.springframework.pulsar.core.CacheProviderFactoryTests$TestCacheProviderFactory
|
||||
@@ -38,6 +38,8 @@ import org.apache.pulsar.common.protocol.schema.SchemaHash;
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.core.log.LogAccessor;
|
||||
import org.springframework.lang.Nullable;
|
||||
import org.springframework.pulsar.cache.provider.CacheProvider;
|
||||
import org.springframework.pulsar.cache.provider.CacheProviderFactory;
|
||||
import org.springframework.util.Assert;
|
||||
|
||||
/**
|
||||
|
||||
@@ -46,6 +46,7 @@ import org.junit.jupiter.params.provider.Arguments;
|
||||
import org.junit.jupiter.params.provider.MethodSource;
|
||||
|
||||
import org.springframework.lang.Nullable;
|
||||
import org.springframework.pulsar.cache.provider.CacheProvider;
|
||||
import org.springframework.pulsar.core.CachingPulsarProducerFactory.ProducerCacheKey;
|
||||
import org.springframework.pulsar.core.CachingPulsarProducerFactory.ProducerWithCloseCallback;
|
||||
import org.springframework.test.util.ReflectionTestUtils;
|
||||
|
||||
Reference in New Issue
Block a user