From 2a8a3bfdb4c860537bd48f79ffde8fcfa72163f9 Mon Sep 17 00:00:00 2001
From: Peter Grlica <peter.grlica@gmail.com>
Date: Thu, 28 Oct 2021 10:57:09 +0200
Subject: [PATCH] Added WaitFor to queue eventbus consumer

---
 pkg/messagebus/consumer/eventbus.go | 1 +
 pkg/messagebus/service.go           | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/pkg/messagebus/consumer/eventbus.go b/pkg/messagebus/consumer/eventbus.go
index 0d8deabce..7e05d2b12 100644
--- a/pkg/messagebus/consumer/eventbus.go
+++ b/pkg/messagebus/consumer/eventbus.go
@@ -11,6 +11,7 @@ import (
 type (
 	Dispatcher interface {
 		Dispatch(ctx context.Context, ev eventbus.Event)
+		WaitFor(ctx context.Context, ev eventbus.Event) (err error)
 	}
 
 	EventbusConsumer struct {
diff --git a/pkg/messagebus/service.go b/pkg/messagebus/service.go
index 26122551b..7f037d067 100644
--- a/pkg/messagebus/service.go
+++ b/pkg/messagebus/service.go
@@ -150,6 +150,8 @@ func (mb *messageBus) Push(q string, p []byte) {
 		return
 	}
 
+	mb.logger.Debug("pushing message", zap.String("queue", q))
+
 	mb.in <- types.Message{P: p, Q: q}
 }