go-linux-mq

Golang mqueue implementation

Usage

package main

import (
    "context"
    mq "github.com/rkorkosz/go-linux-mq"
)

func main() {
    q, err := mq.New(mq.Config{
        Name: "myqueue",
        MaxMsg: 10,
        MsgSize: 1 << 20, // 1 MB
    })
    if err != nil {
        panic(err)
    }
    defer q.Close()

    ctx := context.Background()

    priority := 0

    err = q.Send(ctx, []byte("my new msg"), priority)
    if err != nil {
        panic(err)
    }

    received, err := q.Receive(ctx, priority)
    if err != nil {
        panic(err)
    }
    fmt.Println(string(received))
}