AgentSkillsCN

rabbitmq-skill

利用此技能实现RabbitMQ消费者及其相关基础设施。该技能提供用于创建类型安全消费者的模板，并支持以OpenTelemetry为依托，搭建监听引擎。

SKILL.md
--- frontmatter
name: rabbitmq-skill
description: Use this skill to implement RabbitMQ consumers and infrastructure. It provides templates for creating type-safe consumers and setting up the listening engine with OpenTelemetry support.

RabbitMQ Implementation

This skill provides patterns for robust RabbitMQ consumer implementation.

Execution Steps

Step 1: Create Consumer Handler

Create a new consumer in listener/ (or internal/mq/) using the template.

Template Usage:

  • •Source: templates/consumer.go.tmpl
  • •Target: listener/{{CONSUMER_NAME_LOWER}}.go
  • •Variables:
    • •{{PACKAGE_NAME}}: Package name (e.g., listener)
    • •{{MODULE_NAME}}: Go module name
    • •{{CONSUMER_NAME}}: Consumer struct name (e.g., MatchStatus)
    • •{{MESSAGE_TYPE}}: Struct type of the message (e.g., types.MatchMsg)
    • •{{QUEUE_NAME}}: Queue name

Step 2: Register Listener

In main.go or listener/listener.go (if creating a separate service):

go
// Create consumer instance
consumer := New{{CONSUMER_NAME}}Consumer(ctx, svcCtx)

// Create listener wrapper
l := rabbitmq.NewListener[types.MatchMsg](consumer)

// Start listener
l.Start()

Step 3: Setup Infrastructure (One-time)

If infra/rabbitmq/ does not exist, use templates/infra.go.tmpl (or copy detailed implementation from SKILL Reference) to create the base listener engine.

Templates Location

  • •templates/consumer.go.tmpl: Standard typed consumer handler.
  • •templates/infra.go.tmpl: Infrastructure skeleton (refer to SKILL.md text for full impl if not using library).