rabbitmq

May 15, 2023

Changes in this version

+ func Send(queueExchange QueueExchange, msg interface{}) (err error)

type RabbitMQ

+ func (mq *RabbitMQ) SendDelayMsg(body string, ttl int64) (err error)

+ func (mq *RabbitMQ) SendMsg(body interface{}) (err error)

+ func (mq *RabbitMQ) SendRetryMsg(body string, retry_nums int32, args ...string)

Apr 8, 2023

Changes in this version

+ const DefaultExchangeName

+ const DefaultExchangeType

+ const InitialTimeout

+ func MqStart() (err error)

+ func ReceiveMsg(queueExchange QueueExchange, receiver Receiver, otherParams ...int) (err error)

+ func Recv2(mq RabbitMQ, receiver Receiver, taskQuit chan<- struct{})

+ func SendMsg(queueExchange QueueExchange, msg string) (err error)

+ type MapChild struct

+ Age int

+ Name string

+ type MapTest struct

+ Age int

+ Child MapChild

+ Name string

+ type QueueExchange struct

+ Dns string

+ ExName string

+ ExType string

+ QuName string

+ RtKey string

+ type RabbitMQ struct

+ Channel *amqp.Channel

+ ExchangeName string

+ ExchangeType string

+ QueueName string

+ RoutingKey string

+ var StartQueue *RabbitMQ

+ func NewMq(q QueueExchange) RabbitMQ

+ func (r *RabbitMQ) CloseMqChannel() (err error)

+ func (r *RabbitMQ) CloseMqConnect() (err error)

+ func (r *RabbitMQ) MqConnect() (err error)

+ func (r *RabbitMQ) MqOpenChannel() (err error)

+ type Receiver interface

+ Consumer func([]byte) error

+ FailAction func(error, []byte) error

+ type TestReceive struct

+ func (t *TestReceive) Consumer(byte []byte) error

+ func (t *TestReceive) FailAction(err error, byte []byte) error