EclipseLink JpaConfiguration to depend on TenantResolver (#2242)

minimize dependencies Signed-off-by: Avgustin Marinov <[email protected]>
eclipse-hawkbit · Jan 27, 2025 · 5cc4372 · 5cc4372
1 parent e3c41eb
commit 5cc4372
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/...ry-jpa-eclipselink/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaConfiguration.java b/...ry-jpa-eclipselink/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaConfiguration.java
@@ -34,14 +34,14 @@
 @Configuration
 public class JpaConfiguration extends JpaBaseConfiguration {
 
-    private final TenantAware tenantAware;
+    private final TenantAware.TenantResolver tenantResolver;
 
     protected JpaConfiguration(
             final DataSource dataSource, final JpaProperties properties,
             final ObjectProvider<JtaTransactionManager> jtaTransactionManagerProvider,
-            final TenantAware tenantAware) {
+            final TenantAware.TenantResolver tenantResolver) {
         super(dataSource, properties, jtaTransactionManagerProvider);
-        this.tenantAware = tenantAware;
+        this.tenantResolver = tenantResolver;
     }
 
     /**
@@ -53,7 +53,7 @@ protected JpaConfiguration(
     @Override
     @Bean
     public PlatformTransactionManager transactionManager(final ObjectProvider<TransactionManagerCustomizers> transactionManagerCustomizers) {
-        return new MultiTenantJpaTransactionManager(tenantAware);
+        return new MultiTenantJpaTransactionManager(tenantResolver);
     }
 
     @Override

diff --git a/...nk/src/main/java/org/eclipse/hawkbit/repository/jpa/MultiTenantJpaTransactionManager.java b/...nk/src/main/java/org/eclipse/hawkbit/repository/jpa/MultiTenantJpaTransactionManager.java
@@ -38,7 +38,7 @@ class MultiTenantJpaTransactionManager extends JpaTransactionManager {
     @Serial
     private static final long serialVersionUID = 1L;
 
-    private transient TenantAware tenantAware;
+    private transient TenantAware.TenantResolver tenantResolver;
 
     private static final Class<?> JPA_TARGET;
 
@@ -52,8 +52,8 @@ class MultiTenantJpaTransactionManager extends JpaTransactionManager {
         }
     }
 
-    MultiTenantJpaTransactionManager(final TenantAware tenantAware) {
-        this.tenantAware = tenantAware;
+    MultiTenantJpaTransactionManager(final TenantAware.TenantResolver tenantResolver) {
+        this.tenantResolver = tenantResolver;
     }
 
     private static final EntityPropertyChangeListener ENTITY_PROPERTY_CHANGE_LISTENER = new EntityPropertyChangeListener();
@@ -78,7 +78,7 @@ protected void doBegin(final Object transaction, final TransactionDefinition def
             }
         }
 
-        final String currentTenant = tenantAware.getCurrentTenant();
+        final String currentTenant = tenantResolver.resolveTenant();
         if (currentTenant == null) {
             cleanupTenant(em);
         } else {