in servicebus/Servicebus.go [104:120]
func (s *ServiceBusSender) SendMessage(ctx context.Context, message []byte) error {
logger := ctxlogger.GetLogger(ctx)
logger.Info("Sending message through service bus sender.")
packagedMessage := &azservicebus.Message{
Body: message,
}
err := s.Sender.SendMessage(ctx, packagedMessage, nil)
if err != nil {
logger.Error("Error Sending message")
return err
}
logger.Info("Message sent successfully!")
return nil
}