workshop setup

AxonIQ · Sep 10, 2024 · 38d4103 · 38d4103
1 parent 0f65516
commit 38d4103
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 24 deletions.
diff --git a/multitenancy/src/main/java/io/axoniq/multitenancy/MultiTenantConfig.java b/multitenancy/src/main/java/io/axoniq/multitenancy/MultiTenantConfig.java
@@ -1,12 +1,6 @@
 package io.axoniq.multitenancy;
 
-import org.axonframework.axonserver.connector.AxonServerConfiguration;
-import org.axonframework.axonserver.connector.AxonServerConnectionManager;
-import org.axonframework.axonserver.connector.event.axon.AxonServerEventStore;
-import org.axonframework.eventsourcing.snapshotting.SnapshotFilter;
 import org.axonframework.extensions.multitenancy.components.TenantConnectPredicate;
-
-import org.axonframework.extensions.multitenancy.configuration.MultiTenantStreamableMessageSourceProvider;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -28,16 +22,5 @@ public ScheduledExecutorService persistentStreamScheduler() {
  .factory());
  }
 
- // UNCOMMENT THIS BEAN TO ENABLE MULTITENANCY WITH MULTIPLE DATA SOURCES
-// @Bean
-// public Function<TenantDescriptor, DataSourceProperties> tenantDataSourceResolver() {
-// return tenant -> {
-// DataSourceProperties properties = new DataSourceProperties();
-// properties.setUrl("jdbc:h2:mem:" + tenant.tenantId());
-// properties.setDriverClassName("org.h2.Driver");
-// properties.setUsername("sa");
-// return properties;
-// };
-// }
 }
 
diff --git a/multitenancy/src/main/resources/application.properties b/multitenancy/src/main/resources/application.properties
@@ -27,10 +27,9 @@ spring.jpa.database-platform=org.hibernate.dialect.H2Dialect
 spring.h2.console.enabled=true
 spring.h2.console.path=/h2-console
 
-
-axon.eventhandling.processors.giftcard.mode=SUBSCRIBING
-axon.eventhandling.processors.giftcard.source=giftcard-bean
-axon.axonserver.persistent-streams[giftcard-bean].name=giftcard
-axon.axonserver.persistent-streams[giftcard-bean].batch-size=100
-axon.axonserver.persistent-streams[giftcard-bean].initial-segment-count=2
-axon.axonserver.persistent-streams[giftcard-bean].initial-position=HEAD
+#TODO Create a new stream that only reads only events from the specific giftcard aggregate
+axon.eventhandling.processors.giftcard.mode=subscribing
+axon.eventhandling.processors.giftcard.source=giftcard-stream1
+axon.axonserver.persistent-streams.giftcard-stream1.batch-size=100
+axon.axonserver.persistent-streams.giftcard-stream1.initial-segment-count=4
+#axon.axonserver.persistent-streams.giftcard-stream1.filter=TODO