Marmelator/database-tenant-commons
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'RED-9331' into 'main'

Browse Source 
RED-9331: Explore possibilities for fair upload / analysis processing per tenant

See merge request fforesight/database-tenant-commons!29
This commit is contained in:
Maverick Studer 2024-07-18 14:54:48 +02:00
commit 2282b398f0
4 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
build.gradle.kts
View File

@ -29,7 +29,7 @@ val springCloudVersion = "4.0.4"
dependencies {
api("com.fasterxml.jackson.core:jackson-databind:2.15.2:")
api("com.knecon.fforesight:tenant-commons:0.24.0")
api("com.knecon.fforesight:tenant-commons:0.26.0")
api("com.zaxxer:HikariCP:5.0.1")
api("com.google.guava:guava:32.1.2-jre")
api("org.liquibase:liquibase-core:4.20.0")

4
src/main/java/com/knecon/fforesight/databasetenantcommons/TenantMessagingConfiguration.java
View File

@ -16,13 +16,13 @@ import lombok.RequiredArgsConstructor;
@RequiredArgsConstructor
public class TenantMessagingConfiguration {
@Value("${fforesight.multitenancy.tenant-created-queue:tenant-created}")
@Value("${fforesight.multitenancy.tenant-created-queue:tenant-created-queue}")
private String tenantCreatedEventQueue;
@Value("${fforesight.multitenancy.tenant-created-dlq:tenant-created-dlq}")
private String tenantCreatedDLQ;
@Value("${fforesight.multitenancy.tenant-sync-queue:tenant-sync}")
@Value("${fforesight.multitenancy.tenant-sync-queue:tenant-sync-queue}")
private String tenantSyncEventQueue;
@Value("${fforesight.multitenancy.tenant-sync-dlq:tenant-sync-dlq}")

4
src/main/java/com/knecon/fforesight/databasetenantcommons/providers/TenantCreatedListener.java
View File

@ -18,7 +18,7 @@ public class TenantCreatedListener {
private final TenantLiquibaseInitializer tenantLiquibaseInitializer;
@Value("${fforesight.multitenancy.tenant-created-queue:tenant-created}")
@Value("${fforesight.multitenancy.tenant-created-queue:tenant-created-queue}")
private String tenantCreatedQueue;
@ -30,7 +30,7 @@ public class TenantCreatedListener {
@SneakyThrows
@RabbitListener(queues = "${fforesight.multitenancy.tenant-created-queue:tenant-created}")
@RabbitListener(queues = "${fforesight.multitenancy.tenant-created-queue:tenant-created-queue}")
public void createTenant(TenantCreatedEvent tenantRequest) {
tenantLiquibaseInitializer.initializeTenant(tenantRequest.getTenantId());

4
src/main/java/com/knecon/fforesight/databasetenantcommons/providers/TenantSyncListener.java
View File

@ -20,7 +20,7 @@ public class TenantSyncListener {
private final Optional<TenantSyncService> tenantSyncServices;
@Value("${fforesight.multitenancy.tenant-sync-queue:tenant-sync}")
@Value("${fforesight.multitenancy.tenant-sync-queue:tenant-sync-queue}")
private String tenantSyncQueue;
@ -32,7 +32,7 @@ public class TenantSyncListener {
@SneakyThrows
@RabbitListener(queues = "${fforesight.multitenancy.tenant-sync-queue:tenant-sync}")
@RabbitListener(queues = "${fforesight.multitenancy.tenant-sync-queue:tenant-sync-queue}")
public void createTenant(TenantSyncEvent tenantSyncEvent) {
tenantSyncServices.ifPresent(t -> t.syncTenant(tenantSyncEvent));