in servicebus/Servicebus.go [87:102]
func (sb *ServiceBus) NewServiceBusSender(ctx context.Context, queue string, options *azservicebus.NewSenderOptions) (SenderInterface, error) {
logger := ctxlogger.GetLogger(ctx)
logger.Info("Creating new service bus sender.")
sender, err := sb.Client.NewSender(queue, options)
if err != nil {
logger.Error("Error getting the sender")
return nil, err
}
serviceBusSender := &ServiceBusSender{
Sender: sender,
}
return serviceBusSender, nil
}