{"record":{"id":"91c5cca63a4334db","repo":"t8y2/dbx","slug":"empty-rocketmq-endpoint","errorCode":null,"errorMessage":"empty RocketMQ endpoint","messagePattern":"empty RocketMQ endpoint","errorType":"validation","errorClass":null,"httpStatus":null,"severity":"error","filePath":"agents/drivers/rocketmq/routing.go","lineNumber":57,"sourceCode":"\tmu              sync.RWMutex\n\tconfig          connectionConfig\n\tbyOriginal      map[string]*proxyEndpoint\n\toriginalByLocal map[string]string\n\troutedOwners    map[string]string\n\tclosed          bool\n}\n\nfunc newProxyManager(config connectionConfig) *proxyManager {\n\treturn &proxyManager{\n\t\tconfig: config, byOriginal: map[string]*proxyEndpoint{},\n\t\toriginalByLocal: map[string]string{}, routedOwners: map[string]string{},\n\t}\n}\n\nfunc (manager *proxyManager) ProxyFor(original string, kind proxyTargetKind) (string, error) {\n\toriginal = strings.TrimSpace(original)\n\tif original == \"\" {\n\t\treturn \"\", fmt.Errorf(\"empty RocketMQ endpoint\")\n\t}\n\tmanager.mu.RLock()\n\tif endpoint := manager.byOriginal[original]; endpoint != nil {\n\t\taddress := endpoint.listener.Addr().String()\n\t\tmanager.mu.RUnlock()\n\t\treturn address, nil\n\t}\n\tmanager.mu.RUnlock()\n\n\tmanager.mu.Lock()\n\tdefer manager.mu.Unlock()\n\tif manager.closed {\n\t\treturn \"\", fmt.Errorf(\"RocketMQ proxy manager is closed\")\n\t}\n\tif endpoint := manager.byOriginal[original]; endpoint != nil {\n\t\treturn endpoint.listener.Addr().String(), nil\n\t}\n\ttargets, fallback := manager.routeTargetsLocked(original, kind)","sourceCodeStart":39,"sourceCodeEnd":75,"githubUrl":"https://github.com/t8y2/dbx/blob/c0390bff16418b651f4728520d99adf8ce48829a/agents/drivers/rocketmq/routing.go#L39-L75","documentation":"Returned by proxyManager.ProxyFor in the rocketmq driver when the broker endpoint string passed for proxying is empty after trimming. The proxy manager routes traffic through local listeners to private brokers; an empty target is invalid input rejected before any mapping lookup.","triggerScenarios":"Thrown at agents/drivers/rocketmq/routing.go:57 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Ensure the broker/name-server endpoint passed in (from route info or broker_addr) is a non-empty host:port","Check upstream discovery data for missing endpoint fields before calling ProxyFor"],"exampleFix":null,"handlingStrategy":"validation","validationCode":null,"typeGuard":null,"tryCatchPattern":null,"preventionTips":[],"tags":[],"backgroundTag":null,"analyzedSha":"c0390bff16418b651f4728520d99adf8ce48829a","analyzedAt":"2026-09-05T23:05:10.900Z","contentChangedAt":"2026-09-05T23:05:10.900Z","schemaVersion":2},"datasetVersion":"2026-09-14T05:17:10.506Z"}