rabbitmq

Documentation

Index

• func FailOnError(err error, msg string)
• type Client
  • func NewClient(config *config.RabbitmqConfig, queueNames []string) (*Client, error)
  • func NewClientFromEtcd(etcdCli *etcd.Client, appName, profile string, queueNames []string) (mqCli *Client, err error)
  • func (c *Client) ConsumeMessage(ctx context.Context, msg *amqp.Delivery, f func())
  • func (c *Client) PublishMessage(ctx context.Context, exhcange, key string, immediate bool, msg amqp.Publishing) error

Functions

func FailOnError

func FailOnError(err error, msg string)

FailOnError mq fail

Types

type Client

type Client struct {
	Conn   *amqp.Connection
	Chs    map[string]*amqp.Channel
	Queues map[string]amqp.Queue
	Tracer opentracing.Tracer
	Closer io.Closer
}

Client ..

func NewClient

func NewClient(config *config.RabbitmqConfig, queueNames []string) (*Client, error)

NewClient ..

func NewClientFromEtcd

func NewClientFromEtcd(etcdCli *etcd.Client, appName, profile string, queueNames []string) (mqCli *Client, err error)

NewClientFromEtcd init gorm from etcd config and watch config to update gorm

func (*Client) ConsumeMessage

func (c *Client) ConsumeMessage(ctx context.Context, msg *amqp.Delivery, f func())

func (*Client) PublishMessage

func (c *Client) PublishMessage(ctx context.Context, exhcange, key string, immediate bool, msg amqp.Publishing) error

PublishMessage ..