lepus

Simple wrapper around streadway/amqp with syncronous functions.

Installation

Install:

go get -u github.com/edadeal/lepus

Import:

import "github.com/edadeal/lepus"

Quickstart

func main() {
    conn, err := amqp.Dial("amqp://lepus:lepus@127.0.0.1:5672/lepus")
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()
    ch, err := lepus.SyncChannel(conn.Channel())
    if err != nil {
        t.Fatal(err)
    }
    _, err = ch.QueueDeclare(
        "test", // name
        true,   // durable
        false,  // delete when unused
        false,  // exclusive
        false,  // no-wait
        nil,    // arguments
    )
    if err != nil {
        t.Fatal(err)
    }
    state, err := ch.PublishAndWait(
        "",     // exchange
        "test", // routing key
        true,   // mandatory
        false,
        amqp.Publishing{
            DeliveryMode: amqp.Persistent,
            ContentType:  "text/plain",
            Body:         []byte("Hello, lepus!"),
        },
    )
    if err != nil {
        t.Fatal(err)
    }
    log.Printf("Published: %t", state == lepus.StatePublished)
}