.
This commit is contained in:
parent
a29fe16f32
commit
53505ec1f3
@ -70,6 +70,8 @@ func addObsNotificationToCache(notification *BuildNotification) {
|
|||||||
func processObsMessage(msg *rabbitmq.Delivery) {
|
func processObsMessage(msg *rabbitmq.Delivery) {
|
||||||
out.Write([]byte(msg.Timestamp.String()))
|
out.Write([]byte(msg.Timestamp.String()))
|
||||||
out.Write([]byte("\n"))
|
out.Write([]byte("\n"))
|
||||||
|
out.Write([]byte(msg.RoutingKey))
|
||||||
|
out.Write([]byte("\n"))
|
||||||
out.Write(msg.Body)
|
out.Write(msg.Body)
|
||||||
out.Write([]byte("\n--------------------------\n"))
|
out.Write([]byte("\n--------------------------\n"))
|
||||||
return
|
return
|
||||||
|
Loading…
Reference in New Issue
Block a user