rabbitmq

README

micro-rabbitmq

go-micro broker plugin for rabbitmq

original code here https://github.com/micro/go-plugins

Documentation

Overview

Package rabbitmq provides a RabbitMQ broker

Index

• func DurableExchange() broker.Option
• func DurableQueue() broker.SubscribeOption
• func Exchange(e string) broker.Option
• func Headers(h map[string]interface{}) broker.SubscribeOption
• func NewBroker(opts ...broker.Option) broker.Broker
• func PrefetchCount(c int) broker.SubscribeOption

Functions

func DurableExchange

func DurableExchange() broker.Option

DurableExchange creates an option for durable exchange when subscribing.

func DurableQueue

func DurableQueue() broker.SubscribeOption

DurableQueue creates a durable queue when subscribing.

func Exchange

func Exchange(e string) broker.Option

Exchange is an option to set the Exchange

func Headers

func Headers(h map[string]interface{}) broker.SubscribeOption

Headers adds headers used by the headers exchange

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

NewBroker creates new rabbitmq broker

func PrefetchCount

func PrefetchCount(c int) broker.SubscribeOption

PrefetchCount creates an option for rmq QoS.