rabbitmq

package module
v0.0.0-...-c9a32d2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 18, 2018 License: Apache-2.0 Imports: 11 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

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.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL