Upgrade wildfly-clustering to 1.0.7.Final.

wildfly-clustering · Mar 3, 2024 · b3f6495 · b3f6495
1 parent 5212aa8
commit b3f6495
Show file tree

Hide file tree

Showing 38 changed files with 212 additions and 588 deletions.
diff --git a/context/core/pom.xml b/context/core/pom.xml
@@ -42,7 +42,7 @@
 		</dependency>
 		<dependency>
 			<groupId>org.wildfly.clustering</groupId>
-			<artifactId>wildfly-clustering-session-spi</artifactId>
+			<artifactId>wildfly-clustering-session-spec-spi</artifactId>
 		</dependency>
 	</dependencies>
 </project>
diff --git a/...ain/java/org/wildfly/clustering/spring/context/config/SessionManagementConfiguration.java b/...ain/java/org/wildfly/clustering/spring/context/config/SessionManagementConfiguration.java
@@ -29,6 +29,7 @@
 import org.wildfly.clustering.session.SessionManagerConfiguration;
 import org.wildfly.clustering.session.SessionManagerFactory;
 import org.wildfly.clustering.session.SessionManagerFactoryConfiguration;
+import org.wildfly.clustering.session.spec.SessionSpecificationProvider;
 import org.wildfly.clustering.spring.context.SessionManagerBean;
 import org.wildfly.clustering.spring.context.SessionMarshallerFactory;
 import org.wildfly.common.function.Functions;
@@ -37,7 +38,7 @@
  * Spring configuration bean for a distributable session repository.
  * @author Paul Ferraro
  */
-public abstract class SessionManagementConfiguration<S, C, L> implements SessionManagerFactoryConfiguration<S, C, L, Void>, SessionManagerConfiguration<C>, EnvironmentAware, ImportAware, ResourceLoaderAware, Consumer<AnnotationAttributes> {
+public abstract class SessionManagementConfiguration<S, C, L> implements SessionManagerFactoryConfiguration<Void>, SessionManagerConfiguration<C>, EnvironmentAware, ImportAware, ResourceLoaderAware, Consumer<AnnotationAttributes>, Supplier<SessionSpecificationProvider<S, C, L>> {
 
 	private final Class<? extends Annotation> annotationClass;
 

diff --git a/...ly/clustering/spring/context/infinispan/embedded/InfinispanSessionManagerFactoryBean.java b/...ly/clustering/spring/context/infinispan/embedded/InfinispanSessionManagerFactoryBean.java
@@ -32,23 +32,26 @@
 import org.wildfly.clustering.session.infinispan.embedded.InfinispanSessionManagerFactory;
 import org.wildfly.clustering.session.infinispan.embedded.InfinispanSessionManagerFactoryConfiguration;
 import org.wildfly.clustering.session.infinispan.embedded.metadata.SessionMetaDataKey;
+import org.wildfly.clustering.session.spec.SessionSpecificationProvider;
 import org.wildfly.clustering.spring.context.AutoDestroyBean;
 
 /**
  * @author Paul Ferraro
  */
 public class InfinispanSessionManagerFactoryBean<S, C, L> extends AutoDestroyBean implements SessionManagerFactory<C, Void, TransactionBatch>, InitializingBean {
 
-	private final SessionManagerFactoryConfiguration<S, C, L, Void> configuration;
+	private final SessionManagerFactoryConfiguration<Void> configuration;
+	private final SessionSpecificationProvider<S, C, L> provider;
 	private final InfinispanConfiguration infinispan;
 	private final ChannelEmbeddedCacheManagerCommandDispatcherFactoryConfiguration embeddedCacheManagerConfiguration;
 
 	private SessionManagerFactory<C, Void, TransactionBatch> sessionManagerFactory;
 
-	public InfinispanSessionManagerFactoryBean(SessionManagerFactoryConfiguration<S, C, L, Void> configuration, InfinispanConfiguration infinispan, ChannelEmbeddedCacheManagerCommandDispatcherFactoryConfiguration embeddedCacheManagerConfiguration) {
+	public InfinispanSessionManagerFactoryBean(SessionManagerFactoryConfiguration<Void> configuration, SessionSpecificationProvider<S, C, L> provider, InfinispanConfiguration infinispan, ChannelEmbeddedCacheManagerCommandDispatcherFactoryConfiguration embeddedCacheManagerConfiguration) {
+		this.configuration = configuration;
+		this.provider = provider;
 		this.infinispan = infinispan;
 		this.embeddedCacheManagerConfiguration = embeddedCacheManagerConfiguration;
-		this.configuration = configuration;
 	}
 
 	@Override
@@ -120,7 +123,7 @@ public CacheContainerCommandDispatcherFactory getCommandDispatcherFactory() {
 			}
 		};
 
-		this.sessionManagerFactory = new InfinispanSessionManagerFactory<>(this.configuration, infinispanConfiguration);
+		this.sessionManagerFactory = new InfinispanSessionManagerFactory<>(this.configuration, this.provider, infinispanConfiguration);
 		this.accept(this.sessionManagerFactory::close);
 	}
 

diff --git a/...ain/java/org/wildfly/clustering/spring/context/infinispan/remote/HotRodConfiguration.java b/...ain/java/org/wildfly/clustering/spring/context/infinispan/remote/HotRodConfiguration.java
@@ -15,5 +15,4 @@ public interface HotRodConfiguration {
 	URI getUri();
 	Properties getProperties();
 	String getTemplateName();
-	int getExpirationThreadPoolSize();
 }
diff --git a/.../wildfly/clustering/spring/context/infinispan/remote/HotRodSessionManagerFactoryBean.java b/.../wildfly/clustering/spring/context/infinispan/remote/HotRodSessionManagerFactoryBean.java
@@ -13,27 +13,30 @@
 import org.infinispan.client.hotrod.configuration.TransactionMode;
 import org.springframework.beans.factory.InitializingBean;
 import org.wildfly.clustering.cache.infinispan.batch.TransactionBatch;
+import org.wildfly.clustering.cache.infinispan.remote.RemoteCacheConfiguration;
 import org.wildfly.clustering.session.SessionManager;
 import org.wildfly.clustering.session.SessionManagerConfiguration;
 import org.wildfly.clustering.session.SessionManagerFactory;
 import org.wildfly.clustering.session.SessionManagerFactoryConfiguration;
-import org.wildfly.clustering.session.infinispan.remote.HotRodSessionFactoryConfiguration;
 import org.wildfly.clustering.session.infinispan.remote.HotRodSessionManagerFactory;
+import org.wildfly.clustering.session.spec.SessionSpecificationProvider;
 import org.wildfly.clustering.spring.context.AutoDestroyBean;
 
 /**
  * @author Paul Ferraro
  */
 public class HotRodSessionManagerFactoryBean<S, C, L> extends AutoDestroyBean implements SessionManagerFactory<C, Void, TransactionBatch>, InitializingBean {
 
-	private final SessionManagerFactoryConfiguration<S, C, L, Void> configuration;
+	private final SessionManagerFactoryConfiguration<Void> configuration;
+	private final SessionSpecificationProvider<S, C, L> specProvider;
 	private final HotRodConfiguration hotrod;
 	private final RemoteCacheContainerProvider provider;
 
 	private SessionManagerFactory<C, Void, TransactionBatch> sessionManagerFactory;
 
-	public HotRodSessionManagerFactoryBean(SessionManagerFactoryConfiguration<S, C, L, Void> configuration, HotRodConfiguration hotrod, RemoteCacheContainerProvider provider) {
+	public HotRodSessionManagerFactoryBean(SessionManagerFactoryConfiguration<Void> configuration, SessionSpecificationProvider<S, C, L> specProvider, HotRodConfiguration hotrod, RemoteCacheContainerProvider provider) {
 		this.hotrod = hotrod;
+		this.specProvider = specProvider;
 		this.provider = provider;
 		this.configuration = configuration;
 	}
@@ -47,26 +50,20 @@ public void afterPropertiesSet() throws Exception {
 
 		container.getConfiguration().addRemoteCache(deploymentName, builder -> builder.forceReturnValues(false).nearCacheMode(maxActiveSessions.isEmpty() ? NearCacheMode.DISABLED : NearCacheMode.INVALIDATED).transactionMode(TransactionMode.NONE).templateName(templateName));
 
-		int expirationThreadPoolSize = this.hotrod.getExpirationThreadPoolSize();
 		RemoteCache<?, ?> cache = container.getCache(deploymentName);
 
 		cache.start();
 		this.accept(cache::stop);
 
-		HotRodSessionFactoryConfiguration hotrodConfiguration = new HotRodSessionFactoryConfiguration() {
-			@Override
-			public int getExpirationThreadPoolSize() {
-				return expirationThreadPoolSize;
-			}
-
+		RemoteCacheConfiguration hotrodConfiguration = new RemoteCacheConfiguration() {
 			@SuppressWarnings("unchecked")
 			@Override
 			public <CK, CV> RemoteCache<CK, CV> getCache() {
 				return (RemoteCache<CK, CV>) cache;
 			}
 		};
 
-		this.sessionManagerFactory = new HotRodSessionManagerFactory<>(this.configuration, hotrodConfiguration);
+		this.sessionManagerFactory = new HotRodSessionManagerFactory<>(this.configuration, this.specProvider, hotrodConfiguration);
 		this.accept(this.sessionManagerFactory::close);
 	}
 

diff --git a/...a/org/wildfly/clustering/spring/context/infinispan/remote/MutableHotRodConfiguration.java b/...a/org/wildfly/clustering/spring/context/infinispan/remote/MutableHotRodConfiguration.java
@@ -27,6 +27,4 @@ default void setProperties(Properties properties) {
 	void setProperty(String name, String value);
 
 	void setTemplateName(String templateName);
-
-	void setExpirationThreadPoolSize(int size);
 }
diff --git a/...g/wildfly/clustering/spring/context/infinispan/remote/config/HotRodConfigurationBean.java b/...g/wildfly/clustering/spring/context/infinispan/remote/config/HotRodConfigurationBean.java
@@ -20,7 +20,6 @@ public class HotRodConfigurationBean implements MutableHotRodConfiguration {
 	private URI uri;
 	private Properties properties = new Properties();
 	private String templateName = DefaultTemplate.DIST_SYNC.getTemplateName();
-	private int expirationThreadPoolSize = 16;
 	private StringValueResolver resolver = value -> value;
 
 	@Override
@@ -43,11 +42,6 @@ public String getTemplateName() {
 		return this.templateName;
 	}
 
-	@Override
-	public int getExpirationThreadPoolSize() {
-		return this.expirationThreadPoolSize;
-	}
-
 	@Override
 	public void setUri(String uri) {
 		this.uri = URI.create(this.resolver.resolveStringValue(uri));
@@ -63,11 +57,6 @@ public void setTemplateName(String templateName) {
 		this.templateName = this.resolver.resolveStringValue(templateName);
 	}
 
-	@Override
-	public void setExpirationThreadPoolSize(int size) {
-		this.expirationThreadPoolSize = size;
-	}
-
 	@Override
 	public void accept(AnnotationAttributes attributes) {
 		AnnotationAttributes config = attributes.getAnnotation("config");

diff --git a/pom.xml b/pom.xml
@@ -36,20 +36,20 @@
 		<version.org.kohsuke.metainf-services>1.11</version.org.kohsuke.metainf-services>
 
 		<!-- Runtime dependency versions -->
-		<version.io.projectreactor.core>3.6.2</version.io.projectreactor.core>
+		<version.io.projectreactor.core>3.6.3</version.io.projectreactor.core>
 		<version.org.springframework>6.1.4</version.org.springframework>
 		<version.org.springframework.security>6.2.2</version.org.springframework.security>
 		<version.org.springframework.session>3.2.1</version.org.springframework.session>
 		<version.org.infinispan>14.0.25.Final</version.org.infinispan>
 		<version.org.jboss.marshalling>2.1.4.Final</version.org.jboss.marshalling>
-		<version.org.wildfly.clustering>1.0.6.Final</version.org.wildfly.clustering>
+		<version.org.wildfly.clustering>1.0.7.Final</version.org.wildfly.clustering>
 
 		<!-- Test dependency versions -->
 		<version.org.apache.tomcat>10.1.19</version.org.apache.tomcat>
 		<version.org.jboss.arquillian>1.8.0.Final</version.org.jboss.arquillian>
 		<version.org.jboss.arquillian.container.tomcat>1.1.0.Final</version.org.jboss.arquillian.container.tomcat>
 		<version.org.junit>5.10.2</version.org.junit>
-		<version.org.mockito>5.10.0</version.org.mockito>
+		<version.org.mockito>5.11.0</version.org.mockito>
 		<version.org.testcontainers>1.19.6</version.org.testcontainers>
 	</properties>
 

diff --git a/session/core/pom.xml b/session/core/pom.xml
@@ -41,6 +41,10 @@
 			<groupId>org.springframework.session</groupId>
 			<artifactId>spring-session-core</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.wildfly.clustering</groupId>
+			<artifactId>wildfly-clustering-session-spec-servlet-6.0</artifactId>
+		</dependency>
 
 		<dependency>
 			<groupId>org.springframework.security</groupId>
@@ -55,6 +59,13 @@
 			<scope>test</scope>
 		</dependency>
 
+		<dependency>
+			<groupId>org.wildfly.clustering</groupId>
+			<artifactId>wildfly-clustering-session-spi</artifactId>
+			<classifier>tests</classifier>
+			<scope>test</scope>
+		</dependency>
+
 		<dependency>
 			<groupId>org.infinispan.protostream</groupId>
 			<artifactId>protostream-processor</artifactId>

diff --git a/...re/src/main/java/org/wildfly/clustering/spring/session/ImmutableSessionDestroyAction.java b/...re/src/main/java/org/wildfly/clustering/spring/session/ImmutableSessionDestroyAction.java
@@ -10,6 +10,7 @@
 
 import jakarta.servlet.ServletContext;
 import jakarta.servlet.http.HttpSession;
+import jakarta.servlet.http.HttpSessionActivationListener;
 import jakarta.servlet.http.HttpSessionBindingEvent;
 import jakarta.servlet.http.HttpSessionBindingListener;
 
@@ -18,6 +19,7 @@
 import org.springframework.session.Session;
 import org.wildfly.clustering.cache.batch.Batch;
 import org.wildfly.clustering.session.ImmutableSession;
+import org.wildfly.clustering.session.spec.SessionSpecificationProvider;
 import org.wildfly.clustering.session.user.User;
 import org.wildfly.clustering.session.user.UserManager;
 
@@ -28,19 +30,21 @@ public class ImmutableSessionDestroyAction<B extends Batch> implements BiConsume
 
 	private final ApplicationEventPublisher publisher;
 	private final ServletContext context;
+	private final SessionSpecificationProvider<HttpSession, ServletContext, HttpSessionActivationListener> provider;
 	private final UserConfiguration<B> indexing;
 
-	public ImmutableSessionDestroyAction(ApplicationEventPublisher publisher, ServletContext context, UserConfiguration<B> indexing) {
+	public ImmutableSessionDestroyAction(ApplicationEventPublisher publisher, ServletContext context, SessionSpecificationProvider<HttpSession, ServletContext, HttpSessionActivationListener> provider, UserConfiguration<B> indexing) {
 		this.publisher = publisher;
 		this.context = context;
+		this.provider = provider;
 		this.indexing = indexing;
 	}
 
 	@Override
 	public void accept(ImmutableSession session, BiFunction<Object, Session, ApplicationEvent> eventFactory) {
 		ApplicationEvent event = eventFactory.apply(this, new DistributableImmutableSession(session));
 		this.publisher.publishEvent(event);
-		HttpSession httpSession = JakartaServletFacadeProvider.INSTANCE.asSession(session, this.context);
+		HttpSession httpSession = this.provider.asSession(session, this.context);
 		for (Map.Entry<String, HttpSessionBindingListener> entry : session.getAttributes().getAttributes(HttpSessionBindingListener.class).entrySet()) {
 			HttpSessionBindingListener listener = entry.getValue();
 			try {