in servicebus/Servicebus.go [70:85]
func (sb *ServiceBus) NewServiceBusReceiver(ctx context.Context, topicOrQueue string, options *azservicebus.ReceiverOptions) (ReceiverInterface, error) {
logger := ctxlogger.GetLogger(ctx)
logger.Info("Creating new service bus receiver.")
receiver, err := sb.Client.NewReceiverForQueue(topicOrQueue, options)
if err != nil {
logger.Error("Error getting receiver.")
return nil, err
}
serviceBusReceiver := &ServiceBusReceiver{
Receiver: receiver,
}
return serviceBusReceiver, nil
}