41 lines
751 B
Go
41 lines
751 B
Go
|
package rabbitmq
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
|
||
|
|
"github.com/logrusorgru/aurora"
|
||
|
|
"github.com/streadway/amqp"
|
||
|
|
)
|
||
|
|
|
||
|
|
// SubscribeQueue ...
|
||
|
|
func SubscribeQueue(queueName string) {
|
||
|
|
_, err := channel.QueueDeclare(
|
||
|
|
queueName, // name
|
||
|
|
true, // durable
|
||
|
|
false, // delete when unused
|
||
|
|
false, // exclusive
|
||
|
|
false, // no-wait
|
||
|
|
nil, // arguments
|
||
|
|
)
|
||
|
|
|
||
|
|
if err != nil {
|
||
|
|
fmt.Println("*** Declare failed subscriber queue "+queueName, err.Error())
|
||
|
|
} else {
|
||
|
|
fmt.Println(aurora.Green("*** RabbitMQ - Declared queue: " + queueName))
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// GetMessagesFromQueue ...
|
||
|
|
func GetMessagesFromQueue(queueName string) <-chan amqp.Delivery {
|
||
|
|
messages, _ := channel.Consume(
|
||
|
|
queueName,
|
||
|
|
"",
|
||
|
|
true,
|
||
|
|
false,
|
||
|
|
false,
|
||
|
|
false,
|
||
|
|
nil,
|
||
|
|
)
|
||
|
|
return messages
|
||
|
|
}
|