verify subscriber does not receive massegas different by the ones spe…

…cified in subscriptions
event-driven-io · Jul 1, 2024 · 10a6eec · 10a6eec
1 parent 933e504
commit 10a6eec
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/src/Tests/When_Subscription_Already_Exists.cs b/src/Tests/When_Subscription_Already_Exists.cs
@@ -32,6 +32,9 @@ public async Task Read_from_transaction_log()
         var ( _, subscriptionOptions) = SetupFor<SubscriberUserCreated>(connectionString, eventsTable,
             SubscriberContext.Default, sharedNamingPolicy, testOutputHelper.WriteLine, publicationName: publicationName, slotName: slotName);
 
+        //subscriber ignored msg
+        await MessageAppender.AppendAsync(eventsTable, new PublisherUserDeleted(Guid.NewGuid(), Guid.NewGuid().ToString()), publisherResolver, connectionString, ct);
+
         var @event = new PublisherUserCreated(Guid.NewGuid(), Guid.NewGuid().ToString());
         await MessageAppender.AppendAsync(eventsTable, @event, publisherResolver, connectionString, ct);
 

diff --git a/src/Tests/When_Subscription_Does_Not_Exist_And_Table_Is_Not_Empty.cs b/src/Tests/When_Subscription_Does_Not_Exist_And_Table_Is_Not_Empty.cs
@@ -22,10 +22,9 @@ public async Task Read_from_table_using_named_transaction_snapshot()
             .JsonContext(PublisherContext.Default)
             .NamingPolicy(sharedNamingPolicy)
             .Build();
-        {
-            var @event1 = new PublisherUserDeleted(Guid.NewGuid(), Guid.NewGuid().ToString());
-            await MessageAppender.AppendAsync(eventsTable, @event1, resolver, connectionString, ct);
-        }
+
+        //subscriber ignored msg
+        await MessageAppender.AppendAsync(eventsTable, new PublisherUserDeleted(Guid.NewGuid(), Guid.NewGuid().ToString()), resolver, connectionString, ct);
 
         var @event = new PublisherUserCreated(Guid.NewGuid(), Guid.NewGuid().ToString());
         await MessageAppender.AppendAsync(eventsTable, @event, resolver, connectionString, ct);