amqp

Documentation

Index

• func GetRocketClient() mq_http_sdk.MQClient
• type Rabbit
  • func NewRabbit(addr, accessKey, secretKey, vhost string) *Rabbit
  • func (m *Rabbit) Close()
  • func (m *Rabbit) PublishOnQueue(exchangeName, exchangeType, queueName, key, tag string, durableQueue bool, ...) error
  • func (m *Rabbit) String() string
  • func (m *Rabbit) SubscribeToQueue(exchangeName, exchangeType, queueName, key, tag string, durableQueue bool, ...) error
• type Rocket
  • func NewRocket(client mq_http_sdk.MQClient, ...) *Rocket
  • func (m *Rocket) Close()
  • func (m *Rocket) PublishOnQueue(exchangeName, exchangeType, queueName, key, tag string, durableQueue bool, ...) error
  • func (m *Rocket) String() string
  • func (m *Rocket) SubscribeToQueue(exchangeName, exchangeType, queueName, consumerName string, tag string, ...) error

Functions

func GetRocketClient

func GetRocketClient() mq_http_sdk.MQClient

GetRocketClient 获取sms客户端

Types

type Rabbit

type Rabbit struct {
	// contains filtered or unexported fields
}

func NewRabbit

func NewRabbit(addr, accessKey, secretKey, vhost string) *Rabbit

NewRabbit redis模式

func (*Rabbit) Close

func (m *Rabbit) Close()

Close 关闭连接

func (*Rabbit) PublishOnQueue

func (m *Rabbit) PublishOnQueue(exchangeName, exchangeType, queueName, key, tag string, durableQueue bool, body interface{}) error

PublishOnQueue 发布消息

func (*Rabbit) String

func (m *Rabbit) String() string

String 字符

func (*Rabbit) SubscribeToQueue

func (m *Rabbit) SubscribeToQueue(exchangeName, exchangeType, queueName, key, tag string, durableQueue bool, consumerExclusive bool, handlerFunc message.AmqpConsumerFunc) error

type Rocket

type Rocket struct {
	// contains filtered or unexported fields
}

func NewRocket

func NewRocket(client mq_http_sdk.MQClient, endpoint, accessKey, secretKey, instanceId, namespace string) *Rocket

NewRocket redis模式

func (*Rocket) Close

func (m *Rocket) Close()

Close 关闭连接

func (*Rocket) PublishOnQueue

func (m *Rocket) PublishOnQueue(exchangeName, exchangeType, queueName, key, tag string, durableQueue bool, body interface{}) error

PublishOnQueue 发布消息

func (*Rocket) String

func (m *Rocket) String() string

String 字符

func (*Rocket) SubscribeToQueue

func (m *Rocket) SubscribeToQueue(exchangeName, exchangeType, queueName, consumerName string, tag string, durableQueue bool, consumerExclusive bool, handlerFunc message.AmqpConsumerFunc) error