amqp

Documentation

Index

• Constants
• func BytesToString(b *[]byte) *string
• type AmqpClient
• type Channel
  • 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)

Constants

const Profile = "amqp"

Functions

func BytesToString

func BytesToString(b *[]byte) *string

Types

type AmqpClient

type AmqpClient interface {
	Connect() (cha *amqp.Channel, err error)
	Close()
}

type Channel

type Channel struct {
	*amqp.Channel
}

func NewChannel

func NewChannel() (chn *Channel)

func (*Channel) Connect

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

func (*Channel) PublishDirect

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

func (*Channel) PublishFanout

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

func (*Channel) Receive

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

func (*Channel) ReceiveFanout

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