Class MensageriaController

java.lang.Object

br.com.xadm.comum.mensageria.MensageriaController

@Controller("/admin/mensageria")
@ExecuteOn("blocking")
public class MensageriaController
extends Object

Tela de operador /admin/mensageria (JTE xadm/mensageria.jte, decisão 0025). Lista as mensagens (filtro opcional por direcao/status, mais recentes primeiro) e oferece as ações reenviar/cancelar — só em linhas de saída. Gate por MensageriaAdminRule. Os POSTs usam @Consumes(ALL) porque o form não manda corpo (senão o framework devolve 415).

Fora do event loop (@ExecuteOn(BLOCKING)): toda rota lê ou altera a outbox por JDBC. A lib não conta com o micronaut.server.thread-selection: AUTO do adotante — sem ele, o default MANUAL rodaria a query na thread do Netty.

Constructor Summary

Constructors

Constructor	Description
MensageriaController(MensagemM2mRepository repositorio, MensageriaService servico)

Method Summary

Modifier and Type	Method	Description
io.micronaut.http.HttpResponse<?>	cancelar(long id)	Cancela (→ CANCELADO); o relay ignora.
Map<String,Object>	listar(Optional<Direcao> direcao, Optional<Status> status)	Lista (mais recentes primeiro), com filtro fino aplicado em memória (volume de admin).
io.micronaut.http.HttpResponse<?>	reenviar(long id)	Reenvia (→ PENDENTE, zera tentativas); próximo tick do relay refaz o envio.

Methods inherited from class Object

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

Constructor Details

MensageriaController

public MensageriaController(MensagemM2mRepository repositorio,
 MensageriaService servico)

Method Details

listar

@Get
@Produces("text/html")
@View("xadm/mensageria")
public Map<String,Object> listar(@QueryValue
 Optional<Direcao> direcao,
 @QueryValue
 Optional<Status> status)

Lista (mais recentes primeiro), com filtro fino aplicado em memória (volume de admin).

reenviar

@Post("/{id}/reenviar")
@Consumes("*/*")
public io.micronaut.http.HttpResponse<?> reenviar(@PathVariable
 long id)

Reenvia (→ PENDENTE, zera tentativas); próximo tick do relay refaz o envio.

cancelar

@Post("/{id}/cancelar")
@Consumes("*/*")
public io.micronaut.http.HttpResponse<?> cancelar(@PathVariable
 long id)

Cancela (→ CANCELADO); o relay ignora.