refs #4858

@@ -30,16 +30,23 @@ module.exports = Self => {
         const recipient = to.replace('@', '');
 

@@ -35,0 +37,4 @@
+            tx = await Self.beginTransaction({});
+            myOptions.transaction = tx;
+        }
+

@@ -44,4 +39,2 @@
             throw new Error(`Could not send message "${message}" to worker id ${recipientId} from user ${userId}`);
 
-        if (process.env.NODE_ENV == 'test')
-            message = `[Test:Environment to user ${userId}] ` + message;