Árvore de páginas

Versões comparadas

Chave

  • Esta linha foi adicionada.
  • Esta linha foi removida.
  • A formatação mudou.

...

Bloco de código
languagejava
themeMidnight
linenumberstrue
collapsetrue
@AllArgsConstructor
@EnableBinding(COLENTChannel.class)
public class ArquivoSubscriber {

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

	@StreamListener(target = COLENTChannel.INPUT_NAME, condition = UploadArquivoCmd.CONDITIONAL_EXPRESSION)
	public void uploadArquivo(TOTVSMessage<UploadArquivoCmd> cmd) {
		if (verificarTenantValidoService.tenantValido(cmd)) {
			try {
				var cmd = ArquivoCmdAssembler.toCommand(message.getContent());
				service.handle(cmd);O
 canal de saída também podeO canal de saída também pode    }} 
            catch (Exception exception) {
				serviceRejeitada.handle(ArquivoCmdAssembler.toCommand(cmd, exception));
			}
		}
	}
}

...