amqp

package
v0.0.0-...-54de5a7 Latest Latest
Warning

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

Go to latest
Published: Mar 22, 2021 License: Unlicense Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var UnknownQueue = errors.New("This is a unknown queue.")

Functions

func NewBroker

func NewBroker(url string, exchanges []string, queues []string, queueBindings []*QueueBinding) (asynctask.Broker, error)

Types

type QueueBinding

type QueueBinding struct {
	Queue      string
	BindingKey string
	Exchange   string
}

Jump to

Keyboard shortcuts

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