Pular para o conteúdo principal
Use client.queues() para acompanhar mensagens e operacoes pendentes de uma instancia. Campos comuns em todas as chamadas:
CampoTipoObrigatórioDescrição
instanceIdstringSimID da instância.
instanceTokenstringSimToken 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.