message

Documentation

Index

• func RabbitMq(queueName string, exchange string, key string, mqUrl string) websockets.Subscriber
• type RabbitmqMessage
  • func (r *RabbitmqMessage) Conn()
  • func (r *RabbitmqMessage) Consumer(server *websockets.Server)
  • func (r *RabbitmqMessage) Destroy()
  • func (r *RabbitmqMessage) Producer(c *websockets.Client, message websockets.SubscriberMessage)

Functions

func RabbitMq

func RabbitMq(queueName string, exchange string, key string, mqUrl string) websockets.Subscriber

Types

type RabbitmqMessage

type RabbitmqMessage struct {

	//队列名称
	QueueName string
	//交换机名称
	Exchange string
	//bind Key 名称
	Key string
	//连接信息
	MqUrl string
	// contains filtered or unexported fields
}

func (*RabbitmqMessage) Conn

func (r *RabbitmqMessage) Conn()

func (*RabbitmqMessage) Consumer

func (r *RabbitmqMessage) Consumer(server *websockets.Server)

Consumer 订阅模式消费端代码

func (*RabbitmqMessage) Destroy

func (r *RabbitmqMessage) Destroy()

Destroy 断开channel 和 connection

func (*RabbitmqMessage) Producer

func (r *RabbitmqMessage) Producer(c *websockets.Client, message websockets.SubscriberMessage)

Producer 订阅模式生产