impl

Documentation

Index

• type MQClient
  • func GetMQClient() *MQClient
  • func NewClient(dsn string) (*MQClient, error)
  • func (mq *MQClient) Close()
  • func (mq *MQClient) Consumer(queueName string) (<-chan amqp.Delivery, error)
  • func (mq *MQClient) GetCtx() *gin.Context
  • func (mq *MQClient) Init() error
  • func (mq *MQClient) Name() string
  • func (mq *MQClient) Publish(c *gin.Context, queueName string, body interface{}, ...) error
  • func (mq *MQClient) RetrieveResultChannel(queueName string) chan interface{}
  • func (mq *MQClient) StoreResultChannel(queueName string, resultChan chan interface{})

Types

type MQClient

type MQClient struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
	// contains filtered or unexported fields
}

func GetMQClient

func GetMQClient() *MQClient

func NewClient

func NewClient(dsn string) (*MQClient, error)

func (*MQClient) Close

func (mq *MQClient) Close()

func (*MQClient) Consumer

func (mq *MQClient) Consumer(queueName string) (<-chan amqp.Delivery, error)

func (*MQClient) GetCtx

func (mq *MQClient) GetCtx() *gin.Context

func (*MQClient) Init

func (mq *MQClient) Init() error

func (*MQClient) Name

func (mq *MQClient) Name() string

func (*MQClient) Publish

func (mq *MQClient) Publish(c *gin.Context, queueName string, body interface{}, resultChan chan interface{}) error

func (*MQClient) RetrieveResultChannel

func (mq *MQClient) RetrieveResultChannel(queueName string) chan interface{}

func (*MQClient) StoreResultChannel

func (mq *MQClient) StoreResultChannel(queueName string, resultChan chan interface{})