decrease logs output
This commit is contained in:
parent
00e4b4c82a
commit
4ba77f6631
@ -46,7 +46,7 @@ func PublishHandler(w http.ResponseWriter, r *http.Request) {
|
|||||||
queueName := r.FormValue("queue")
|
queueName := r.FormValue("queue")
|
||||||
go Register(queueName, msg)
|
go Register(queueName, msg)
|
||||||
|
|
||||||
Log("Published message of %d bytes to queue %s", len(msg), queueName)
|
Debug("Published message of %d bytes to queue %s", len(msg), queueName)
|
||||||
w.Write([]byte("OK"))
|
w.Write([]byte("OK"))
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -81,7 +81,7 @@ func SubscriptionHandler(w http.ResponseWriter, r *http.Request) {
|
|||||||
w.Header().Set("Queue", res.Queue)
|
w.Header().Set("Queue", res.Queue)
|
||||||
w.Write(res.Message)
|
w.Write(res.Message)
|
||||||
|
|
||||||
Log("Recieved message of %d bytes from queue %s", len(res.Message), res.Queue)
|
Debug("Recieved message of %d bytes from queue %s", len(res.Message), res.Queue)
|
||||||
finished <- true
|
finished <- true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user