Added Qos support
parent
67ba48a3db
commit
9aa886de9a
|
@ -42,11 +42,19 @@ func Init() {
|
||||||
log.Fatalln("Failed to open a channel", err)
|
log.Fatalln("Failed to open a channel", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
defer ch.Close()
|
//defer ch.Close()
|
||||||
|
|
||||||
Channel = ch
|
Channel = ch
|
||||||
|
|
||||||
log.Debug("RabbitMQ connected")
|
err = ch.Qos(
|
||||||
|
1, // prefetch count
|
||||||
|
0, // prefetch size
|
||||||
|
false, // global
|
||||||
|
)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
log.Fatalln("Failed to set QoS", err)
|
||||||
|
}
|
||||||
|
|
||||||
msgs, err := ch.Consume(
|
msgs, err := ch.Consume(
|
||||||
"mails", // queue
|
"mails", // queue
|
||||||
|
@ -66,7 +74,7 @@ func Init() {
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
for d := range msgs {
|
for d := range msgs {
|
||||||
fmt.Printf("Recieved Message: %s\n", d.Body)
|
log.Debugf("Recieved Message: %s\n", d.Body)
|
||||||
|
|
||||||
log.Info("aa")
|
log.Info("aa")
|
||||||
|
|
||||||
|
@ -84,7 +92,7 @@ func Init() {
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
fmt.Println("Successfully Connected to our RabbitMQ Instance")
|
log.Info("Successfully Connected to our RabbitMQ Instance")
|
||||||
fmt.Println(" [*] - Waiting for messages")
|
log.Debug(" [*] - Waiting for messages")
|
||||||
<-forever
|
<-forever
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue