{"record":{"id":"01d164b6e49f501c","repo":"ruvnet/ruflo","slug":"eventbus-emit-failed-for-eventname-err-insta","errorCode":null,"errorMessage":"EventBus emit failed for ${eventName}: ${err instanceof Error ? err.message : err}","messagePattern":"EventBus emit failed for (.+?): (.+?)","errorType":"console","errorClass":null,"httpStatus":null,"severity":"error","filePath":"v3/@claude-flow/plugin-agent-federation/src/application/inbound-dispatcher.ts","lineNumber":480,"sourceCode":"      messageId: message.id,\n      authorizationMode,\n      authorizationAllowed: authorizationDecision?.allowed,\n    },\n  });\n\n  // Emit typed event for the integrator\n  // Examples: federation:inbound:task, federation:inbound:memory-query\n  const eventName = `${FEDERATION_INBOUND_EVENT_PREFIX}:${message.type}`;\n  try {\n    deps.eventBus.emit(eventName, {\n      address,\n      sourceNodeId,\n      message,\n      peer,\n    });\n  } catch (err) {\n    // EventBus throw should not crash the receive loop.\n    deps.logger.warn(\n      `EventBus emit failed for ${eventName}: ${err instanceof Error ? err.message : err}`,\n    );\n  }\n\n  return { accepted: true, sourceNodeId, messageType: message.type };\n}\n","sourceCodeStart":462,"sourceCodeEnd":487,"githubUrl":"https://github.com/ruvnet/ruflo/blob/fa13ee4ad60ac2090b1480656eb233521790d640/v3/@claude-flow/plugin-agent-federation/src/application/inbound-dispatcher.ts#L462-L487","documentation":"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.","triggerScenarios":"Thrown at v3/@claude-flow/plugin-agent-federation/src/application/inbound-dispatcher.ts:480 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["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."],"exampleFix":null,"handlingStrategy":"try-catch","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"fa13ee4ad60ac2090b1480656eb233521790d640","analyzedAt":"2026-08-18T21:34:22.708Z","contentChangedAt":"2026-08-18T21:34:22.708Z","schemaVersion":2},"datasetVersion":"2026-09-14T00:17:10.932Z"}