Documentation ¶
Index ¶
- Constants
- Variables
- func Close()
- func Init() (err error)
- type ClientRabbitMQ
- func (mq *ClientRabbitMQ) Channel() (err error)
- func (mq *ClientRabbitMQ) Connect() (err error)
- func (mq *ClientRabbitMQ) Consume(messages chan []byte) (err error)
- func (mq *ClientRabbitMQ) ExchangeDeclare(ex string) (err error)
- func (mq *ClientRabbitMQ) Keepalive()
- func (mq *ClientRabbitMQ) Print()
- func (mq *ClientRabbitMQ) Publish(ex string, rk string, body string) (err error)
- func (mq *ClientRabbitMQ) QueueBinds(ex string, bindingKeys []string) (err error)
- func (mq *ClientRabbitMQ) QueueDeclare(queueName string) (err error)
Constants ¶
View Source
const Exchange string = "ex.project.topic"
View Source
const QueueName string = "queue.project"
View Source
const RoutingKey string = "rk.project"
Variables ¶
View Source
var BindingKeys = []string{
"rk.*",
}
View Source
var MQ = new(ClientRabbitMQ)
Functions ¶
Types ¶
type ClientRabbitMQ ¶
type ClientRabbitMQ struct {
// contains filtered or unexported fields
}
func (*ClientRabbitMQ) Channel ¶
func (mq *ClientRabbitMQ) Channel() (err error)
func (*ClientRabbitMQ) Connect ¶
func (mq *ClientRabbitMQ) Connect() (err error)
func (*ClientRabbitMQ) Consume ¶
func (mq *ClientRabbitMQ) Consume(messages chan []byte) (err error)
func (mq *ClientRabbitMQ) Consume() (mqMsg <-chan amqp.Delivery, err error) {
func (*ClientRabbitMQ) ExchangeDeclare ¶
func (mq *ClientRabbitMQ) ExchangeDeclare(ex string) (err error)
func (*ClientRabbitMQ) Keepalive ¶
func (mq *ClientRabbitMQ) Keepalive()
func (*ClientRabbitMQ) Print ¶
func (mq *ClientRabbitMQ) Print()
func (*ClientRabbitMQ) Publish ¶
func (mq *ClientRabbitMQ) Publish(ex string, rk string, body string) (err error)
func (*ClientRabbitMQ) QueueBinds ¶
func (mq *ClientRabbitMQ) QueueBinds(ex string, bindingKeys []string) (err error)
func (*ClientRabbitMQ) QueueDeclare ¶
func (mq *ClientRabbitMQ) QueueDeclare(queueName string) (err error)
Click to show internal directories.
Click to hide internal directories.