broker in go

main.go
// Connect to RabbitMQ
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
    log.Fatalf("Failed to connect to RabbitMQ: %v", err)
}
defer conn.Close()

// Open a channel
ch, err := conn.Channel()
if err != nil {
    log.Fatalf("Failed to open a channel: %v", err)
}
defer ch.Close()

// Declare a queue
q, err := ch.QueueDeclare(
    "myqueue", // name
    false,    // durable
    false,    // delete when unused
    false,    // exclusive
    false,    // no-wait
    nil,      // arguments
)
if err != nil {
    log.Fatalf("Failed to declare a queue: %v", err)
}

// Publish a message
err = ch.Publish(
    "",      // exchange
    q.Name,  // routing key
    false,   // mandatory
    false,   // immediate
    amqp.Publishing{
        ContentType: "text/plain",
        Body:        []byte("Hello, World!"),
    })
if err != nil {
    log.Fatalf("Failed to publish a message: %v", err)
}

// Consume messages
msgs, err := ch.Consume(
    q.Name, // queue
    "",     // consumer
    true,   // auto-ack
    false,  // exclusive
    false,  // no-local
    false,  // no-wait
    nil,    // arguments
)
if err != nil {
    log.Fatalf("Failed to register a consumer: %v", err)
}
for msg := range msgs {
    log.Printf("Received a message: %s", msg.Body)
}
1286 chars
58 lines