rabbitmq

package
v1.0.6 Latest Latest
Warning

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

Go to latest
Published: Dec 19, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Addr string `mapstructure:"addr"`
}

type Msg

type Msg struct {
	Data   any // 发送的内容
	Method string
	Time   time.Time
}

func (Msg) Msg

func (m Msg) Msg(data []byte) Msg

func (Msg) String

func (m Msg) String() []byte

type Rabbitmq

type Rabbitmq struct {
	Conn    *amqp.Connection
	Channel *amqp.Channel
}

func NewRabbitmq

func NewRabbitmq(c Config) *Rabbitmq

func (*Rabbitmq) Connection

func (r *Rabbitmq) Connection(c Config) error

func (*Rabbitmq) Destroy

func (r *Rabbitmq) Destroy()

Jump to

Keyboard shortcuts

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