Commit 1941bdb3 authored by handolukats's avatar handolukats
Browse files

TEIS-305 added classifier update listeners

parent 446b703e
......@@ -24,13 +24,22 @@ public class DomainCacheConfig implements DomainCacheList {
}
@RabbitListener(queues = "#{@classifierItemCacheUpdateService.cacheResponseQueueName}")
public void classifierItemCacheResponseEvent(ClassifierItemCacheUpdateService.ClassifierItemCacheResponseDTO cacheResponseDTO){
public void classifierItemCacheResponseEvent(ClassifierItemCacheUpdateService.ClassifierItemCacheResponseDTO cacheResponseDTO) {
classifierItemCacheUpdateService.processSnapshot(cacheResponseDTO.getPayload(), cacheResponseDTO.getRequestMetaDTO());
}
@RabbitListener(queues = "#{@classifierDefinitionCacheUpdateService.cacheResponseQueueName}")
public void classifierDefinitionCacheResponseEvent(ClassifierDefinitionCacheUpdateService.ClassifierDefinitionCacheResponseDTO cacheResponseDTO){
public void classifierDefinitionCacheResponseEvent(ClassifierDefinitionCacheUpdateService.ClassifierDefinitionCacheResponseDTO cacheResponseDTO) {
classifierDefinitionCacheUpdateService.processSnapshot(cacheResponseDTO.getPayload(), cacheResponseDTO.getRequestMetaDTO());
}
@RabbitListener(queues = "#{@classifierItemCacheUpdateService.createdEventsQueueName}")
public void classifierItemCreatedEvent(ClassifierItemCacheUpdateService.ClassifierItemCreatedDTO createdDTO) {
classifierItemCacheUpdateService.created(createdDTO.getPayload());
}
@RabbitListener(queues = "#{@classifierItemCacheUpdateService.updatedEventsQueueName}")
public void classifierItemCreatedEvent(ClassifierItemCacheUpdateService.ClassifierItemUpdatedDTO updatedDTO) {
classifierItemCacheUpdateService.updated(updatedDTO.getPayload().getId(), updatedDTO.getPayload());
}
}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment