rabbitmq

Documentation

Index

• Constants
• type ChannelCloseListener
• type Config
• type Rabbit
  • func CreateRabbit(c Config) (*Rabbit, error)
  • func (r *Rabbit) Close()
  • func (r *Rabbit) CloseChannel(channel *amqp091.Channel)
  • func (r *Rabbit) CreateChannel() (*amqp091.Channel, error)
  • func (r *Rabbit) Disconnected() bool
  • func (r *Rabbit) GetConfig() *Config
  • func (r *Rabbit) SetChannelCloseListener(channel *amqp091.Channel, listener ChannelCloseListener)

Constants

const (
	Direct  = "direct"
	Topic   = "topic"
	Fanout  = "fanout"
	Headers = "headers"
)

const DefaultReconnectInterval = 2

Types

type ChannelCloseListener

type ChannelCloseListener func()

type Config

type Config struct {
	Enable            bool   `mapstructure:"enable"`
	Url               string `mapstructure:"url"`
	Vhost             string `mapstructure:"vhost"`
	Locale            string `mapstructure:"locale"`
	ReconnectInterval int    `mapstructure:"reconnectInterval"` // 断线重连的频率，单位：秒，默认2秒
}

type Rabbit

type Rabbit struct {
	// contains filtered or unexported fields
}

func CreateRabbit

func CreateRabbit(c Config) (*Rabbit, error)

func (*Rabbit) Close

func (r *Rabbit) Close()

func (*Rabbit) CloseChannel

func (r *Rabbit) CloseChannel(channel *amqp091.Channel)

func (*Rabbit) CreateChannel

func (r *Rabbit) CreateChannel() (*amqp091.Channel, error)

func (*Rabbit) Disconnected

func (r *Rabbit) Disconnected() bool

func (*Rabbit) GetConfig

func (r *Rabbit) GetConfig() *Config

func (*Rabbit) SetChannelCloseListener

func (r *Rabbit) SetChannelCloseListener(channel *amqp091.Channel, listener ChannelCloseListener)