36 lines
1.3 KiB
Java
36 lines
1.3 KiB
Java
package eu.eudat.integrationevent.outbox.dmptouched;
|
|
|
|
import eu.eudat.integrationevent.outbox.OutboxIntegrationEvent;
|
|
import eu.eudat.integrationevent.outbox.OutboxService;
|
|
import eu.eudat.integrationevent.outbox.tenantremoval.TenantRemovalIntegrationEventHandlerImpl;
|
|
import gr.cite.tools.logging.LoggerService;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.config.ConfigurableBeanFactory;
|
|
import org.springframework.context.annotation.Scope;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
import java.util.UUID;
|
|
|
|
@Component
|
|
@Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE)
|
|
public class DmpTouchedIntegrationEventHandlerImpl implements DmpTouchedIntegrationEventHandler {
|
|
|
|
private static final LoggerService logger = new LoggerService(LoggerFactory.getLogger(DmpTouchedIntegrationEventHandlerImpl.class));
|
|
|
|
private final OutboxService outboxService;
|
|
|
|
public DmpTouchedIntegrationEventHandlerImpl(OutboxService outboxService) {
|
|
this.outboxService = outboxService;
|
|
}
|
|
|
|
@Override
|
|
public void handle(DmpTouchedIntegrationEvent event) {
|
|
OutboxIntegrationEvent message = new OutboxIntegrationEvent();
|
|
message.setMessageId(UUID.randomUUID());
|
|
message.setType(OutboxIntegrationEvent.DMP_TOUCH);
|
|
message.setEvent(event);
|
|
this.outboxService.publish(message);
|
|
}
|
|
|
|
}
|