rabbitmq

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

type InvokerCfg struct {
	Host string `ini:"host"`
}

type PubSub struct {
	*RabbitMQ
}

type RabbitImp interface {
	Publish(string) error
	Receive(func(amqp.Delivery))
	Destroy()
}

type RabbitMQ struct {

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

type Routing struct {
	*RabbitMQ
}

type Simple struct {
	*RabbitMQ
}

type Topic struct {
	*RabbitMQ
}