Use client.queues() para acompanhar mensagens e operacoes pendentes de uma instancia.
Campos comuns em todas as chamadas:
| Campo | Tipo | Obrigatório | Descrição |
|---|
instanceId | string | Sim | ID da instância. |
instanceToken | string | Sim | Token da instância. |
client.queues().listMessages(...)
Lista a fila de mensagens pendentes.
var options = InstanceRequestOptions.builder().instanceToken(instanceToken).build();
JsonNode result = client.queues().listMessages(GenericInstanceRequest.builder()
.instanceId(instanceId)
.instanceToken(instanceToken)
.build());
// Exemplo: tipagem estrita com DTOs publicados quando disponivel
Retorno: envelope { code, success, data } com count e messages[] (id, type, status, etc.).
client.queues().removeMessage(...)
Remove uma mensagem específica da fila.
var options = InstanceRequestOptions.builder().instanceToken(instanceToken).build();
JsonNode result = client.queues().removeMessage(GenericInstanceRequest.builder()
.instanceId(instanceId)
.instanceToken(instanceToken)
.build());
// Exemplo: tipagem estrita com DTOs publicados quando disponivel
Retorno: envelope { code, success, data } com message_id, count, details.
client.queues().purgeMessages(...)
Remove todos os itens pendentes da fila de mensagens. Use apenas quando tiver certeza.
var options = InstanceRequestOptions.builder().instanceToken(instanceToken).build();
JsonNode result = client.queues().purgeMessages(GenericInstanceRequest.builder()
.instanceId(instanceId)
.instanceToken(instanceToken)
.build());
// Exemplo: tipagem estrita com DTOs publicados quando disponivel
Retorno: envelope { code, success, data } com count de itens removidos.
client.queues().listOperations(...)
Lista a fila de operações pendentes.
var options = InstanceRequestOptions.builder().instanceToken(instanceToken).build();
JsonNode result = client.queues().listOperations(GenericInstanceRequest.builder()
.instanceId(instanceId)
.instanceToken(instanceToken)
.build());
// Exemplo: tipagem estrita com DTOs publicados quando disponivel
Retorno: envelope { code, success, data } com fila de operacoes pendentes.
client.queues().removeOperation(...)
Remove uma operação específica da fila.
var options = InstanceRequestOptions.builder().instanceToken(instanceToken).build();
JsonNode result = client.queues().removeOperation(GenericInstanceRequest.builder()
.instanceId(instanceId)
.instanceToken(instanceToken)
.build());
// Exemplo: tipagem estrita com DTOs publicados quando disponivel
Retorno: envelope { code, success, data } com message_id, count, details.
client.queues().purgeOperations(...)
Remove todos os itens pendentes da fila de operações. Use apenas quando tiver certeza.
var options = InstanceRequestOptions.builder().instanceToken(instanceToken).build();
JsonNode result = client.queues().purgeOperations(GenericInstanceRequest.builder()
.instanceId(instanceId)
.instanceToken(instanceToken)
.build());
// Exemplo: tipagem estrita com DTOs publicados quando disponivel
Retorno: envelope { code, success, data } com count de itens removidos.