Class RelayM2m

java.lang.Object

br.com.xadm.comum.mensageria.RelayM2m

@Singleton
public class RelayM2m
extends Object

Relay durável do outbox. A cada fixed-delay carrega o lote de saída (PENDENTE, ERRO) abaixo do teto e despacha cada mensagem pela SPI tipada. Cada transição de estado roda em transação curta própria (via MensageriaService, cross-bean) — isolamento por mensagem: falha (ou exceção inesperada do enviador) marca só aquela linha, o lote segue. Sem lock de linha: sob N instâncias o despacho é AT-LEAST-ONCE e o receptor deduplica.

Constructor Summary

Constructors

Constructor	Description
RelayM2m(MensagemM2mRepository repositorio, RoteadorEnviadores roteador, MensageriaService servico, MensageriaConfig config)

Method Summary

Modifier and Type	Method	Description
int	executar()	Processa um lote de saída.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RelayM2m

public RelayM2m(MensagemM2mRepository repositorio,
 RoteadorEnviadores roteador,
 MensageriaService servico,
 MensageriaConfig config)

Method Details

executar

public int executar()

Processa um lote de saída. Público para o teste exercitar sem depender do agendador.

Returns:

quantidade de mensagens processadas neste passe.