MQ Guide en

MQ Guide (EN)

This page gives a quick usage guide for producers, consumers, and DLQ.

1) Producer (Minimal)

Message m = Message.builder().topic("order_events")
    .data(Map.of("orderId", 123L, "status", "created"))
    .build();
producer.sendAsync(m);

2) Consumer (Group)

consumer.subscribe("order_events", "payment_group", msg -> {
  try { handle(msg); return true; } catch (Exception e) { return false; }
});
consumer.start();

3) Retry & DLQ

• Failed beyond max attempts → written to DLQ: stream:topic:{topic}:dlq
• Replay via Admin/Service, back to original partition

4) Admin Ops (Examples)

• List topics, size, replayAll, delete, clear（see Admin interface in MQ/Starter）

References

• design: MQ-Design-en.md
• broker interaction: docs/redis-mq-broker-interaction.md
• partitioning: docs/redis-mq-partitioning.md