sipeed/picoclaw · error

mqtt subscribe failed: %w

Error message

mqtt subscribe failed: %w

What it means

Error "mqtt subscribe failed: %w" thrown in sipeed/picoclaw.

Source

Thrown at pkg/channels/mqtt/mqtt.go:116

	opts.SetConnectionLostHandler(func(_ pahomqtt.Client, err error) {
		logger.WarnCF("mqtt", "MQTT connection lost", map[string]any{"error": err.Error()})
	})

	client := pahomqtt.NewClient(opts)
	token := client.Connect()
	if !token.WaitTimeout(10 * time.Second) {
		client.Disconnect(250)
		return fmt.Errorf("mqtt connect timed out after 10s (broker: %s)", c.cfg.Broker)
	}
	if err := token.Error(); err != nil {
		client.Disconnect(250)
		return fmt.Errorf("mqtt connect failed: %w", err)
	}

	if err := <-firstSubscribe; err != nil {
		client.Disconnect(250)
		return fmt.Errorf("mqtt subscribe failed: %w", err)
	}

	c.client = client
	c.SetRunning(true)

	logger.InfoCF("mqtt", "MQTT channel started", map[string]any{
		"broker":   c.cfg.Broker,
		"agent_id": c.cfg.AgentID,
	})
	return nil
}

// topicPrefix returns the configured topic prefix, normalizing slashes.
// Trailing slashes are stripped; the result may or may not have a leading slash
// depending on what the user configured.
func (c *MQTTChannel) topicPrefix() string {
	p := strings.TrimRight(c.cfg.TopicPrefix, "/")
	if p == "" {

View on GitHub (pinned to 49183d7e8d)

When it happens

Trigger: Thrown at pkg/channels/mqtt/mqtt.go:116 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of sipeed/picoclaw@49183d7e8d (2026-08-15). Data as JSON: /api/errors/60e3180a801bd633. Report an issue: GitHub.