Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitCluster ¶
type RabbitCluster struct { //队列名称 QueueName string //交换机 Exchange string //KEY Key string //连接信息 Mqurl string // contains filtered or unexported fields }
RabbitCluster RabbitMQ集群
func NewRabbitMQSimple ¶
func NewRabbitMQSimple(username, password, host, vhost, queueName string) (*RabbitCluster, error)
NewRabbitMQSimple 创建简单模式下的实例
func (*RabbitCluster) ConsumeSimple ¶
func (r *RabbitCluster) ConsumeSimple() <-chan amqp.Delivery
ConsumeSimple 简单模式下消费消息
func (*RabbitCluster) PublistSimple ¶
func (r *RabbitCluster) PublistSimple(message []byte) error
PublistSimple 简单模式下发送消息
Click to show internal directories.
Click to hide internal directories.