amqp

Oct 10, 2019

Changes in this version

type Channel

+ func (chn *Channel) Create(queueName, exchange, key, kind string) error

+ func (chn *Channel) CreateFanout(queueName, exchange string) error

+ func (chn *Channel) Push(exchange, key, expiration, mgsConnect string) error

+ type Properties struct

+ Exchange string

+ Host string

+ Password string

+ Port int

+ QueueName string

+ SleepTime int64

+ Username string

Jul 23, 2019

Changes in this version

+ const Profile

+ func BytesToString(b *[]byte) *string

+ type AmqpClient interface

+ Close func()

+ Connect func() (cha *amqp.Channel, err error)

+ type Channel struct

+ func NewChannel() (chn *Channel)

+ func (chn *Channel) Connect(p *properties) (err error)

+ func (chn *Channel) PublishDirect(exchange, queueName, mgsConnect, key string) error

+ func (chn *Channel) PublishFanout(exchange, mgsConnect string) error

+ func (chn *Channel) Receive(queueName string) (*string, error)

+ func (chn *Channel) ReceiveFanout(queueName, exchange string) (*string, error)