Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 订阅模式生产
Source Files
Click to show internal directories.
Click to hide internal directories.