diff --git a/src/sns-server.ts b/src/sns-server.ts
index 465486a..b3b442e 100644
--- a/src/sns-server.ts
+++ b/src/sns-server.ts
@@ -9,7 +9,7 @@ import {
   arrayify,
   createAttr,
   createMetadata,
-  createSnsTopicEvent,
+  createSnsLambdaEvent,
   parseMessageAttributes,
   parseAttributes,
   createMessageId,
@@ -362,13 +362,12 @@ export class SNSServer implements ISNSServer {
             event = message;
           } else {
             event = JSON.stringify(
-              createSnsTopicEvent(
+              createSnsLambdaEvent(
                 topicArn,
                 sub.SubscriptionArn,
                 subject,
                 message,
                 messageId,
-                messageStructure,
                 messageAttributes,
                 messageGroupId
               )