{"record":{"id":"1c22ea44956b67af","repo":"t8y2/dbx","slug":"rocketmq-proxy-manager-is-closed","errorCode":null,"errorMessage":"RocketMQ proxy manager is closed","messagePattern":"RocketMQ proxy manager is closed","errorType":"exception","errorClass":null,"httpStatus":null,"severity":"error","filePath":"agents/drivers/rocketmq/routing.go","lineNumber":70,"sourceCode":"}\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)\n\tlistener, err := net.Listen(\"tcp\", \"127.0.0.1:0\")\n\tif err != nil {\n\t\treturn \"\", fmt.Errorf(\"start RocketMQ endpoint proxy: %w\", err)\n\t}\n\tendpoint := &proxyEndpoint{original: original, targets: targets, fallback: fallback, listener: listener, manager: manager}\n\tlocal := listener.Addr().String()\n\tmanager.byOriginal[original] = endpoint\n\tmanager.originalByLocal[local] = original\n\tgo endpoint.serve()\n\treturn local, nil\n}\n\nfunc (manager *proxyManager) routeTargetsLocked(original string, kind proxyTargetKind) ([]string, bool) {","sourceCodeStart":52,"sourceCodeEnd":88,"githubUrl":"https://github.com/t8y2/dbx/blob/c0390bff16418b651f4728520d99adf8ce48829a/agents/drivers/rocketmq/routing.go#L52-L88","documentation":"Returned by proxyManager.ProxyFor in the rocketmq driver when a new proxy endpoint is requested after the manager was closed (connection teardown). The closed flag makes the proxy fail closed: no new local listeners are created once the client shuts down, preventing dangling proxies.","triggerScenarios":"Thrown at agents/drivers/rocketmq/routing.go:70 when the library encounters an invalid state.","commonSituations":"See trigger scenarios.","solutions":["Do not issue new requests on a closed RocketMQ client; reconnect first","Check for concurrent disconnect/reconnect racing in-flight operations"],"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"}