istra

Go AMQP wrapper

This is an AMQP Library wrapper.

Example

import (
	"github.com/shuvis/istra"
	"github.com/streadway/amqp"
)

func main() {
	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
	if err != nil {
		panic(err)
	}

	err = istra.Process(conn,
		istra.ExchangeDeclare{Exchange: "testExchange", Kind: "fanout", Durable: true},
		istra.QueueDeclare{Name: "testQueue", Durable: true, AutoDelete: true},
		istra.Bind{Queue: "testQueue", Exchange: "testExchange", Topic: "topic"})

	if err != nil {
		panic(err)
	}

	go istra.ConsumeQueue(conn, istra.QueueConf{Name: "testQueue"}, func(d amqp.Delivery) {
		// process delivery
	})

	err = istra.Process(conn,
		istra.UnBind{Queue: "testQueue", Exchange: "testExchange", Topic: "topic"})

	if err != nil {
		panic(err)
	}
}

License

MIT License - see LICENSE for more details.