Added WaitFor to queue eventbus consumer
This commit is contained in:
@@ -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 {
|
||||
|
||||
@@ -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}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user