rabbitmq

package
v0.0.0-...-103677a Latest Latest
Warning

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

Go to latest
Published: Jan 9, 2019 License: Apache-2.0 Imports: 10 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