diff --git a/server/lib/message-sender.js b/server/lib/message-sender.js
index 8d59e677..1ce9313a 100644
--- a/server/lib/message-sender.js
+++ b/server/lib/message-sender.js
@@ -682,7 +682,7 @@ async function queueCampaignMessageTx(tx, sendConfigurationId, listId, subscript
     });
 }
 
-async function queueAPITransactionalMessage(tx, sendConfigurationId, email, subject, html, text, tagLanguage, mergeTags, attachments) {
+async function queueAPITransactionalMessageTx(tx, sendConfigurationId, email, subject, html, text, tagLanguage, mergeTags, attachments) {
     const msgData = {
         to: {
             address: email
@@ -788,4 +788,4 @@ module.exports.queueCampaignMessageTx = queueCampaignMessageTx;
 module.exports.queueSubscriptionMessage = queueSubscriptionMessage;
 module.exports.dropQueuedMessage = dropQueuedMessage;
 module.exports.getMessage = getMessage;
-module.exports.queueAPITransactionalMessage = queueAPITransactionalMessage;
+module.exports.queueAPITransactionalMessageTx = queueAPITransactionalMessageTx;
diff --git a/server/models/templates.js b/server/models/templates.js
index 1d7fb6f4..3613b8e8 100644
--- a/server/models/templates.js
+++ b/server/models/templates.js
@@ -163,13 +163,13 @@ async function remove(context, id) {
 }
 
 async function sendAsTransactionalEmail(context, templateId, sendConfigurationId, emails, subject, mergeTags, attachments) {
-	await knex.transaction(async tx => {
-		const template = await getById(context, templateId, false);
+    const template = await getById(context, templateId, false);
 
-		await shares.enforceEntityPermission(context, 'sendConfiguration', sendConfigurationId, 'sendWithoutOverrides');
+    await shares.enforceEntityPermission(context, 'sendConfiguration', sendConfigurationId, 'sendWithoutOverrides');
 
+    await knex.transaction(async tx => {
 		for (const email of emails) {
-			await messageSender.queueAPITransactionalMessage(tx, sendConfigurationId, email, subject, template.html, template.text, template.tag_language, {...mergeTags,  EMAIL: email }, attachments);
+			await messageSender.queueAPITransactionalMessageTx(tx, sendConfigurationId, email, subject, template.html, template.text, template.tag_language, {...mergeTags,  EMAIL: email }, attachments);
 		}
 	});
 }