def METHOD_NAME(self, mocker):
    filtered_message = "a filtered message"
    mocker.patch("airbyte_cdk.sources.message.repository.filter_secrets", return_value=filtered_message)
    repo = InMemoryMessageRepository(Level.DEBUG)
    repo.log_message(Level.INFO, lambda: "this is a log message")
    assert list(repo.consume_queue())[0].log.message == filtered_message