summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_change_stream_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_change_stream_test.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_change_stream_test.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/pipeline/document_source_change_stream_test.cpp b/src/mongo/db/pipeline/document_source_change_stream_test.cpp
index 501045ceadf..eb2583f705b 100644
--- a/src/mongo/db/pipeline/document_source_change_stream_test.cpp
+++ b/src/mongo/db/pipeline/document_source_change_stream_test.cpp
@@ -1423,8 +1423,8 @@ TEST_F(ChangeStreamStageTest, MatchFiltersCreateCollection) {
TEST_F(ChangeStreamStageTest, MatchFiltersNoOp) {
auto noOp = makeOplogEntry(OpTypeEnum::kNoop, // op type
{}, // namespace
- BSON("msg"
- << "new primary")); // o
+ BSON(repl::ReplicationCoordinator::newPrimaryMsgField
+ << repl::ReplicationCoordinator::newPrimaryMsg)); // o
checkTransformation(noOp, boost::none);
}
@@ -2076,8 +2076,8 @@ TEST_F(ChangeStreamStageDBTest, RenameFromUserToSystemCollectionShouldIncludeNot
TEST_F(ChangeStreamStageDBTest, MatchFiltersNoOp) {
OplogEntry noOp = makeOplogEntry(OpTypeEnum::kNoop,
NamespaceString(),
- BSON("msg"
- << "new primary"));
+ BSON(repl::ReplicationCoordinator::newPrimaryMsgField
+ << repl::ReplicationCoordinator::newPrimaryMsg));
checkTransformation(noOp, boost::none);
}