move to auto config

AxonFramework · Jul 23, 2024 · 0ffd726 · 0ffd726
1 parent 9ac4b3f
commit 0ffd726
Show file tree

Hide file tree

Showing 5 changed files with 4 additions and 9 deletions.
diff --git a/...work/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamAutoConfiguration.java b/...work/extensions/multitenancy/autoconfig/MultiTenantPersistentStreamAutoConfiguration.java
@@ -19,8 +19,6 @@
 import org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSourceFactory;
 import org.axonframework.common.StringUtils;
 import org.axonframework.extensions.multitenancy.components.TenantProvider;
-import org.axonframework.extensions.multitenancy.components.eventstore.MultiTenantPersistentStreamMessageSource;
-import org.axonframework.extensions.multitenancy.components.eventstore.TenantPersistentStreamMessageSourceFactory;
 import org.axonframework.springboot.autoconfig.AxonServerAutoConfiguration;
 import org.springframework.boot.autoconfigure.AutoConfiguration;
 import org.springframework.boot.autoconfigure.AutoConfigureBefore;

diff --git a/...iTenantPersistentStreamMessageSource.java → ...iTenantPersistentStreamMessageSource.java b/...iTenantPersistentStreamMessageSource.java → ...iTenantPersistentStreamMessageSource.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.axonframework.extensions.multitenancy.components.eventstore;
+package org.axonframework.extensions.multitenancy.autoconfig;
 
 
 import io.axoniq.axonserver.connector.event.PersistentStreamProperties;
@@ -22,6 +22,7 @@
 import org.axonframework.extensions.multitenancy.components.MultiTenantAwareComponent;
 import org.axonframework.extensions.multitenancy.components.TenantDescriptor;
 import org.axonframework.common.Registration;
+import org.axonframework.extensions.multitenancy.components.eventstore.MultiTenantSubscribableMessageSource;
 
 import java.util.Collections;
 import java.util.Map;

diff --git a/...PersistentStreamMessageSourceFactory.java → ...PersistentStreamMessageSourceFactory.java b/...PersistentStreamMessageSourceFactory.java → ...PersistentStreamMessageSourceFactory.java
@@ -13,10 +13,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.axonframework.extensions.multitenancy.components.eventstore;
+package org.axonframework.extensions.multitenancy.autoconfig;
 
 import io.axoniq.axonserver.connector.event.PersistentStreamProperties;
-import org.axonframework.axonserver.connector.AxonServerConfiguration;
 import org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSource;
 import org.axonframework.config.Configuration;
 import org.axonframework.extensions.multitenancy.components.TenantDescriptor;

diff --git a/...g/axonframework/extensions/multitenancy/autoconfig/MultiTenancyAutoConfigurationTest.java b/...g/axonframework/extensions/multitenancy/autoconfig/MultiTenancyAutoConfigurationTest.java
@@ -25,7 +25,6 @@
 import org.axonframework.extensions.multitenancy.components.deadletterqueue.MultiTenantDeadLetterQueueFactory;
 import org.axonframework.extensions.multitenancy.components.eventstore.MultiTenantEventStore;
 import org.axonframework.extensions.multitenancy.components.eventstore.TenantEventSegmentFactory;
-import org.axonframework.extensions.multitenancy.components.eventstore.TenantPersistentStreamMessageSourceFactory;
 import org.axonframework.extensions.multitenancy.components.queryhandeling.MultiTenantQueryBus;
 import org.axonframework.extensions.multitenancy.components.queryhandeling.MultiTenantQueryUpdateEmitter;
 import org.axonframework.extensions.multitenancy.components.queryhandeling.TenantQuerySegmentFactory;

diff --git a/...antPersistentStreamMessageSourceTest.java → ...antPersistentStreamMessageSourceTest.java b/...antPersistentStreamMessageSourceTest.java → ...antPersistentStreamMessageSourceTest.java
@@ -13,15 +13,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.axonframework.extensions.multitenancy.components.eventstore;
+package org.axonframework.extensions.multitenancy.autoconfig;
 
 import io.axoniq.axonserver.connector.event.PersistentStreamProperties;
 import org.axonframework.axonserver.connector.event.axon.PersistentStreamMessageSource;
 import org.axonframework.config.Configuration;
-import org.axonframework.extensions.multitenancy.components.eventstore.MultiTenantPersistentStreamMessageSource;
 import org.axonframework.extensions.multitenancy.components.TenantDescriptor;
 import org.axonframework.common.Registration;
-import org.axonframework.extensions.multitenancy.components.eventstore.TenantPersistentStreamMessageSourceFactory;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.mockito.Mock;