pikaq

PikaQ, I choose YOU!

PikaQ makes working with Rabbit MQ even easier. It provides a thin layer around streadway/amqp, the defacto standard golang library for publishing and consuming Rabbit MQ messages. This package makes writing your own high performance message-based services fun and type safe.

The name "pika" is used for any member of the Ochotonidae, a family within the order of lagomorphs, which also includes the Leporidae (rabbits and hares). -- Wikipedia

Install

go get https://github.com/xentek/pikaq

Import

import "github.com/xentek/pikaq"

Usage

The simplest consumer you can create just logs and acks each message it recieves. The example below uses the built in LoggingHandler.

For your consumer, write a function with the following signature: func(pikaq.Messages, chan error), and pass it as the last argument of pikaq.LoggingHandler. Refer to the examples for more information.

package main

import (
	"log"

	"github.com/xentek/pikaq"
)

func main() {
	c, err := pikaq.NewConsumer("amqp://localhost:5672", "amq.direct", "direct", "example-queue", "routing-key", "example", pikaq.LoggingHandler)
	if err != nil {
		log.Fatalf("New Consumer Error: %s", err)
	}
	log.Printf("Started Consumer: %s", c.tag.Tag())
}

Contributing

Refer to our Contributor's Guide to learn how you can participate in this project.