exchange

package
v0.0.0-...-bf7ae8d Latest Latest
Warning

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

Go to latest
Published: Sep 6, 2022 License: MPL-2.0 Imports: 2 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Exchange

type Exchange struct {
	Name        string
	Type        Type
	Durable     bool
	AutoDeleted bool
	Internal    bool
	NoWait      bool
	Args        amqp.Table
	Channel     *amqp.Channel
}

func New

func New(Channel *amqp.Channel) *Exchange

func (*Exchange) Declare

func (config *Exchange) Declare() error

func (*Exchange) From

func (config *Exchange) From(exchange *Exchange) *Exchange

func (*Exchange) WithArgs

func (config *Exchange) WithArgs(Args amqp.Table) *Exchange

func (*Exchange) WithAutoDeleted

func (config *Exchange) WithAutoDeleted(AutoDeleted bool) *Exchange

func (*Exchange) WithChannel

func (config *Exchange) WithChannel(Channel *amqp.Channel) *Exchange

func (*Exchange) WithDurable

func (config *Exchange) WithDurable(Durable bool) *Exchange

func (*Exchange) WithInternal

func (config *Exchange) WithInternal(Internal bool) *Exchange

func (*Exchange) WithName

func (config *Exchange) WithName(Name string) *Exchange

func (*Exchange) WithNoWait

func (config *Exchange) WithNoWait(NoWait bool) *Exchange

func (*Exchange) WithType

func (config *Exchange) WithType(Type Type) *Exchange

type Type

type Type string
const (
	TypeDirect Type = "direct"
	TypeTopic  Type = "topic"
	TypeFanout Type = "fanout"
)

Jump to

Keyboard shortcuts

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