Troubleshooting

const subscription = await client.subscribe("order/*");
console.log("Subscribed to order/*");

// Publisher
await client.publish("order/created", ["partner-id"], data);

// Subscriber - ✅ Will receive
await client.subscribe("order/*");

// Subscriber - ❌ Won't receive
await client.subscribe("payment/*");

// Use the partner's appId, not your own
await client.publish("order/created", ["partner-app-id"], data);

// Run multiple instances with the same appKey
// Each worker processes events in parallel

subscription.on(async (event) => {
  // ❌ Long processing blocks other events
  await longRunningTask(event.payload);
  await event.ack();
});

// ✅ Defer if processing will take time
subscription.on(async (event) => {
  if (needsLongProcessing(event.payload)) {
    await event.defer(60000, "Needs background processing");
    // Process in background job
  } else {
    await processQuickly(event.payload);
    await event.ack();
  }
});

subscription.on(async (event) => {
  if (await isProcessed(event.idem)) {
    await event.ack();
    return;
  }
  
  await processEvent(event);
  await markProcessed(event.idem);
  await event.ack();
});

subscription.on(async (event) => {
  try {
    await processEvent(event);
    await event.ack();  // ✅ Event removed from queue
  } catch (error) {
    await event.defer(5000);  // ✅ Retry later
  }
});

// ❌ Missing ack/defer/discard - event will be redelivered
subscription.on(async (event) => {
  await processEvent(event);
  // Missing ack!
});

// Auto-ack enabled
await client.subscribe("order/*", { autoAck: true });

// Manual ack required
await client.subscribe("order/*", { autoAck: false });