t8y2/dbx · error

empty RocketMQ endpoint

Error message

empty RocketMQ endpoint

What it means

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.

Source

Thrown at agents/drivers/rocketmq/routing.go:57

	mu              sync.RWMutex
	config          connectionConfig
	byOriginal      map[string]*proxyEndpoint
	originalByLocal map[string]string
	routedOwners    map[string]string
	closed          bool
}

func newProxyManager(config connectionConfig) *proxyManager {
	return &proxyManager{
		config: config, byOriginal: map[string]*proxyEndpoint{},
		originalByLocal: map[string]string{}, routedOwners: map[string]string{},
	}
}

func (manager *proxyManager) ProxyFor(original string, kind proxyTargetKind) (string, error) {
	original = strings.TrimSpace(original)
	if original == "" {
		return "", fmt.Errorf("empty RocketMQ endpoint")
	}
	manager.mu.RLock()
	if endpoint := manager.byOriginal[original]; endpoint != nil {
		address := endpoint.listener.Addr().String()
		manager.mu.RUnlock()
		return address, nil
	}
	manager.mu.RUnlock()

	manager.mu.Lock()
	defer manager.mu.Unlock()
	if manager.closed {
		return "", fmt.Errorf("RocketMQ proxy manager is closed")
	}
	if endpoint := manager.byOriginal[original]; endpoint != nil {
		return endpoint.listener.Addr().String(), nil
	}
	targets, fallback := manager.routeTargetsLocked(original, kind)

View on GitHub (pinned to c0390bff16)

Solutions

1. Ensure the broker/name-server endpoint passed in (from route info or broker_addr) is a non-empty host:port
2. Check upstream discovery data for missing endpoint fields before calling ProxyFor

When it happens

Trigger: Thrown at agents/drivers/rocketmq/routing.go:57 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of t8y2/dbx@c0390bff16 (2026-09-05). Data as JSON: /api/errors/91c5cca63a4334db. Report an issue: GitHub.