in servicebus/Servicebus.go [138:161]
func (r *ServiceBusReceiver) ReceiveMessage(ctx context.Context) ([]byte, error) {
logger := ctxlogger.GetLogger(ctx)
logger.Info("Receiving message")
messages, err := r.Receiver.ReceiveMessages(ctx, 1, nil)
if err != nil {
logger.Info("Error receiving message!")
return nil, err
}
var body []byte
for _, message := range messages {
body = message.Body
logger.Info("%s\n" + string(body))
err = r.Receiver.CompleteMessage(ctx, message, nil)
if err != nil {
logger.Info("Error completing message!")
return nil, err
}
}
return body, nil
}