Revert "test"

This reverts commit f008d597e4.
This commit is contained in:
shoopea 2019-06-28 15:55:01 +08:00
parent 81c7b10291
commit 35b0bfcff6

View File

@ -88,25 +88,18 @@ func MQKeepAliveWorker() {
}
//log.Printf("MQKeepAliveWorker : Connected to RabbitMQ")
log.Printf("MQKeepAliveWorker : Session address : %p.\n", &s)
q, err := s.MQChannel.QueueDeclare(
s.Queue, // name
false, // durable
false, // delete when unused
false, // exclusive
false, // no-wait
nil, // arguments
)
m, err := s.MQChannel.Consume(
q.Name, // queue
"", // consumer
true, // auto-ack
false, // exclusive
false, // no-local
false, // no-wait
nil, // args
)
for d := range m {
/*
m, err := s.MQChannel.Consume(
s.MQQueue.Name, // queue
"", // consumer
true, // auto-ack
false, // exclusive
false, // no-local
false, // no-wait
nil, // args
)
*/
for d := range s.MQDelivery {
log.Printf("MQKeepAliveWorker : Received a message: %s", string(d.Body))
x := MQKeepAlive{}
err = json.Unmarshal(d.Body, &x)