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

Fixed some issues with Messaging configuration and copy/paste error

Browse Source
This commit is contained in:
Timo Bejan 2024-09-24 12:40:21 +03:00
parent fdcd0fb40b
commit 5296c2b042
3 changed files with 5 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -14,7 +14,7 @@ import com.knecon.fforesight.tenantcommons.queue.TenantMessagingConfiguration;
@Configuration
public class TenantMessagingConfigurationImpl extends TenantMessagingConfiguration {
public String getTenantSyncQueue() {
public String getTenantSyncQueueName() {
return this.getQueueNameWithSuffix("_tenant_sync");
}
@ -23,7 +23,7 @@ public class TenantMessagingConfigurationImpl extends TenantMessagingConfigurati
@Bean({"tenantSyncQueue"})
public Queue tenantSyncQueue() {
return QueueBuilder.durable(this.getTenantCreatedQueueName())
return QueueBuilder.durable(this.getTenantSyncQueueName())
.withArgument("x-dead-letter-exchange", "")
.withArgument("x-dead-letter-routing-key", this.getTenantEventsDLQName())
.withArgument("x-expires", 300000)

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

@ -18,19 +18,9 @@ public class TenantCreatedListener {
private final TenantLiquibaseInitializer tenantLiquibaseInitializer;
@Value("${fforesight.multitenancy.tenant-created-queue:tenant-created-queue}")
private String tenantCreatedQueue;
@PostConstruct
public void postConstruct() {
log.info("Listener for tenant-created started for queue: {}", tenantCreatedQueue);
}
@SneakyThrows
@RabbitListener(queues = "${fforesight.multitenancy.tenant-created-queue:tenant-created-queue}")
@RabbitListener(queues = "#{tenantMessagingConfigurationImpl.getTenantCreatedQueueName()}")
public void createTenant(TenantCreatedEvent tenantRequest) {
tenantLiquibaseInitializer.initializeTenant(tenantRequest.getTenantId());

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

@ -22,8 +22,8 @@ public class TenantSyncListener {
@SneakyThrows
@RabbitListener(queues = "#{tenantMessagingConfigurationImpl.getTenantSyncQueue()}")
public void createTenant(TenantSyncEvent tenantSyncEvent) {
@RabbitListener(queues = "#{tenantMessagingConfigurationImpl.getTenantSyncQueueName()}")
public void syncTenant(TenantSyncEvent tenantSyncEvent) {
tenantSyncServices.ifPresent(t -> t.syncTenant(tenantSyncEvent));
}