ruvnet/ruflo · error

EventBus emit failed for ${eventName}: ${err instanceof Erro

Error message

EventBus emit failed for ${eventName}: ${err instanceof Error ? err.message : err}

What it means

Log warning in dispatchInbound: emitting the typed inbound event (federation:inbound:<type>) on the integrator's EventBus threw; the emit failure is deliberately contained so it cannot crash the inbound message receive loop.

Source

Thrown at v3/@claude-flow/plugin-agent-federation/src/application/inbound-dispatcher.ts:480

      messageId: message.id,
      authorizationMode,
      authorizationAllowed: authorizationDecision?.allowed,
    },
  });

  // Emit typed event for the integrator
  // Examples: federation:inbound:task, federation:inbound:memory-query
  const eventName = `${FEDERATION_INBOUND_EVENT_PREFIX}:${message.type}`;
  try {
    deps.eventBus.emit(eventName, {
      address,
      sourceNodeId,
      message,
      peer,
    });
  } catch (err) {
    // EventBus throw should not crash the receive loop.
    deps.logger.warn(
      `EventBus emit failed for ${eventName}: ${err instanceof Error ? err.message : err}`,
    );
  }

  return { accepted: true, sourceNodeId, messageType: message.type };
}

View on GitHub (pinned to fa13ee4ad6)

Solutions

  1. Inspect the failing event handler for the named event; a throwing subscriber causes this error and the handler should be fixed or made exception-safe.
Defensive patterns

Strategy: try-catch

When it happens

Trigger: Thrown at v3/@claude-flow/plugin-agent-federation/src/application/inbound-dispatcher.ts:480 when the library encounters an invalid state.

Common situations: See trigger scenarios.


AI-assisted analysis of ruvnet/ruflo@fa13ee4ad6 (2026-08-18). Data as JSON: /api/errors/01d164b6e49f501c. Report an issue: GitHub.