in servicebus/Servicebus.go [53:69]
func CreateServiceBusClientFromConnectionString(ctx context.Context, connectionString string, options *azservicebus.ClientOptions) (ServiceBusClientInterface, error) {
logger := ctxlogger.GetLogger(ctx)
logger.Info("Creating Service Bus from Connection String!")
client, err := azservicebus.NewClientFromConnectionString(connectionString, options)
if err != nil {
logger.Error("Error getting client.")
return nil, err
}
servicebus := &ServiceBus{
Client: client,
}
return servicebus, nil
}