in servicebus/Servicebus.go [26:51]
func CreateServiceBusClient(ctx context.Context, clientUrl string, credential azcore.TokenCredential, options *azservicebus.ClientOptions) (ServiceBusClientInterface, error) {
logger := ctxlogger.GetLogger(ctx)
logger.Info("Creating Service Bus!")
if credential == nil {
var err error
credential, err = azidentity.NewDefaultAzureCredential(nil)
if err != nil {
logger.Error("Error getting token credential")
return nil, err
}
}
client, err := azservicebus.NewClient(clientUrl, credential, options)
if err != nil {
logger.Error("Error getting client.")
return nil, err
}
servicebus := &ServiceBus{
Client: client,
}
return servicebus, nil
}