Histórico da Página

@AllArgsConstructor 
@RabbitListener(queues = QUEUE) 
public class ArquivoSubscriber {
	private static final String QUEUE = "coleta-entrega-exchange.${spring.application.name}"

	private final ArquivoApplicationService service;
	private final VerificarTenantValidoService verificarTenantValidoService;
	private final ArquivoRejeitadoApplicationService serviceRejeitada;

	@RabbitListener
	@RabbitHandler  
    public void uploadArquivo(@Payload UploadArquivoCmd cmd) {
		if (verificarTenantValidoService.tenantValido(cmd)) {
			try {
				var appCmd = ArquivoCmdAssembler.toCommand(cmd);
				service.handle(appCmd);
			} catch (Exception exception) {
				serviceRejeitada.handle(ArquivoCmdAssembler.toCommand(cmd, exception));
			}
		}
	}
}