diff --git a/README.md b/README.md
index d1fa146..856f504 100644
--- a/README.md
+++ b/README.md
@@ -13,8 +13,6 @@ This package is built to easily create products in Akeneo from your ERP or other
 
 Aside from attributes, you can also set a family, categories and all other data you would normally be able to via the [API](https://api.akeneo.com/api-reference.html#Products).
 
-> **Note:** This package does not have support for product models yet.
-
 For more advanced use cases, it is also possible to add your own data to the payload.
 
 Products are retrieved and updated in small chunks to spread the load if your project has access to a lot of products. Updates of these products are only sent to Akeneo if something has been modified to prevent unnecessary requests.
@@ -39,19 +37,20 @@ Publish the configuration of the package.
 php artisan vendor:publish --provider="JustBetter\AkeneoProducts\ServiceProvider" --tag=config
 ```
 
-Add the following command to your scheduler.
+Add the following commands to your scheduler.
 
 ```php
 <?php
 
-use JustBetter\AkeneoProducts\Commands\ProcessProductsCommand;
-
-$schedule->command(ProcessProductsCommand::class)->everyMinute();
+$schedule->command(\JustBetter\AkeneoProducts\Commands\Product\ProcessProductsCommand::class)->everyMinute();
+$schedule->command(\JustBetter\AkeneoProducts\Commands\ProductModel\ProcessProductModelsCommand::class)->everyMinute();
 ```
 
 ## How it works
 
-When a product is retrieved, it will fetch the product from the (external) source. If the retrieved data is not null, it will be saved in the database. If the payload of the model has been changed, the `update`-property of the model will be set to `true`. This way, the package is aware of updates and can do them in small batches. The numbers can be tweaked in your configuration file.
+This section will describe the process of products but product models will be similar in usage.
+
+When a product is retrieved, it will fetch the product from the (external) source. If the retrieved data is not null, it will be saved in the database. If the payload of the database model has been changed, the `update`-property of the model will be set to `true`. This way, the package is aware of updates and can do them in small batches. The numbers can be tweaked in your retriever class.
 
 When a product has already been retrieved in the past, the `retrieve`-property of the model can be set to `true` in order to automatically fetch the data again. This is done by the `ProcessProductsCommand`, if added to your scheduler.
 
@@ -65,9 +64,12 @@ This package does **not** contain a way to retrieve "all" products. If you wish
 ```php
 <?php
 
-use JustBetter\AkeneoProducts\Jobs\RetrieveProductJob;
+use JustBetter\AkeneoProducts\Jobs\Product\RetrieveProductJob;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\RetrieveProductModelJob;
 
 RetrieveProductJob::dispatch('::identifier::');
+
+RetrieveProductModelJob::dispatch('::code::');
 ```
 
 ## Retrieving products
@@ -91,9 +93,9 @@ use JustBetter\AkeneoProducts\Contracts\Akeneo\FormatsAttributeValues;
 use JustBetter\AkeneoProducts\Data\ProductData;
 use JustBetter\AkeneoProducts\Enums\MappingType;
 use JustBetter\AkeneoProducts\Models\Mapping;
-use JustBetter\AkeneoProducts\Retrievers\BaseRetriever;
+use JustBetter\AkeneoProducts\Retrievers\Product\BaseProductRetriever;
 
-class ExampleRetriever extends BaseRetriever
+class ExampleProductRetriever extends BaseProductRetriever
 {
     public function __construct(
         protected FormatsAttributeValues $formatValue
@@ -150,6 +152,27 @@ class ExampleRetriever extends BaseRetriever
 }
 ```
 
+Product models can be implemented similarly use the following example:
+
+```php
+<?php
+
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\BaseProductModelRetriever;
+
+class ExampleProductModelRetriever extends BaseProductModelRetriever
+{
+    public function retrieve(string $code): ?ProductModelData
+    {
+        //
+
+        return ProductModelData::of([
+            //
+        ]);
+    }
+}
+```
+
 ## Supported attribute types
 
 Currently, the following attribute types are supported by this package:
@@ -166,6 +189,8 @@ Currently, the following attribute types are supported by this package:
 
 This package ships with a few commands.
 
+### Products
+
 Retrieve a product by it's identifier, it will automatically be saved to the database.
 
 ```bash
@@ -184,6 +209,26 @@ Update a product by it's identifier. This will manually trigger an update toward
 php artisan akeneo-products:update {identifier}
 ```
 
+### Product models
+
+Retrieve a product model by it's code, it will automatically be saved to the database.
+
+```bash
+php artisan akeneo-products:model:retrieve {code}
+```
+
+Process all product models, this includes retrieving and updating product models.
+
+```bash
+php artisan akeneo-products:model:process
+```
+
+Update a product model by it's code. This will manually trigger an update towards Akeneo, regardless if the product model is up-to-date.
+
+```bash
+php artisan akeneo-products:model:update {code}
+```
+
 ## Quality
 
 To ensure the quality of this package, run the following command:
diff --git a/UPGRADE.md b/UPGRADE.md
new file mode 100644
index 0000000..c533259
--- /dev/null
+++ b/UPGRADE.md
@@ -0,0 +1,35 @@
+# Upgrading
+
+Documentation about upgrading to the next major version.
+
+## From 1.x to 2.x
+
+Since version 2.x, support for product models has been added. By doing so, most classes have been moved to a new namespace. The configuration is also mostly moved to the retriever class itself.
+
+### Namespaces
+
+The retriever class for products has also been changed. Please, update all references to the new namespace.
+
+```php
+use JustBetter\AkeneoProducts\Retrievers\BaseRetriever;
+
+// Is now
+
+use JustBetter\AkeneoProducts\Retrievers\Product\BaseProductRetriever;
+```
+
+All classes related to products have also been moved within the `Product` namespace. This applies to `Actions`, `Jobs`, `Commands`, etc. Make sure to update all references as well.
+
+Example:
+
+```php
+use JustBetter\AkeneoProducts\Jobs\RetrieveProductJob;
+
+// Is now
+
+use JustBetter\AkeneoProducts\Jobs\Product\RetrieveProductJob;
+```
+
+### Configuration
+
+In order to have a more dynamic configuration, the options have been moved to the retriever class itself. If you wish to configure the batch sizes or the amount of tries, add these properties to your retriever class.
diff --git a/config/akeneo-products.php b/config/akeneo-products.php
index c5812e5..1096c8c 100644
--- a/config/akeneo-products.php
+++ b/config/akeneo-products.php
@@ -5,16 +5,13 @@
     /* Determines which queue jobs should be dispatched on. */
     'queue' => 'default',
 
-    /* Max tries before a product sync will automatically be turned off. */
-    'tries' => 3,
+    /* Configuration for the retrievers. */
+    'retrievers' => [
 
-    /* Amount of products to be retrieved at once when processing. */
-    'retrieve_batch_size' => 100,
-
-    /* Amount of products to be updated at once when processing. */
-    'update_batch_size' => 25,
-
-    /* Class responsible to retrieve the products from. */
-    'retriever' => \JustBetter\AkeneoProducts\Retrievers\ProductRetriever::class,
+        /* Class responsible to retrieve the products from. */
+        'product' => \JustBetter\AkeneoProducts\Retrievers\Product\ProductRetriever::class,
 
+        /* Class responsible to retrieve the product models from. */
+        'product_model' => \JustBetter\AkeneoProducts\Retrievers\ProductModel\ProductModelRetriever::class,
+    ],
 ];
diff --git a/database/migrations/2023_08_22_083000_create_akeneo_product_models_table.php b/database/migrations/2023_08_22_083000_create_akeneo_product_models_table.php
new file mode 100644
index 0000000..f3ae8b4
--- /dev/null
+++ b/database/migrations/2023_08_22_083000_create_akeneo_product_models_table.php
@@ -0,0 +1,32 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::create('akeneo_product_models', function (Blueprint $table): void {
+            $table->id();
+            $table->string('code');
+            $table->boolean('synchronize')->default(true);
+            $table->boolean('retrieve')->default(false);
+            $table->boolean('update')->default(false);
+            $table->integer('fail_count')->default(0);
+            $table->json('data');
+            $table->string('checksum')->nullable();
+            $table->timestamp('retrieved_at')->nullable();
+            $table->timestamp('modified_at')->nullable();
+            $table->timestamp('failed_at')->nullable();
+            $table->timestamps();
+            $table->softDeletes();
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::dropIfExists('akeneo_product_models');
+    }
+};
diff --git a/src/Actions/ProcessProducts.php b/src/Actions/Product/ProcessProducts.php
similarity index 69%
rename from src/Actions/ProcessProducts.php
rename to src/Actions/Product/ProcessProducts.php
index 6ead6d4..b89e9a9 100644
--- a/src/Actions/ProcessProducts.php
+++ b/src/Actions/Product/ProcessProducts.php
@@ -1,11 +1,12 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Actions;
+namespace JustBetter\AkeneoProducts\Actions\Product;
 
-use JustBetter\AkeneoProducts\Contracts\ProcessesProducts;
-use JustBetter\AkeneoProducts\Jobs\RetrieveProductJob;
-use JustBetter\AkeneoProducts\Jobs\UpdateProductJob;
+use JustBetter\AkeneoProducts\Contracts\Product\ProcessesProducts;
+use JustBetter\AkeneoProducts\Jobs\Product\RetrieveProductJob;
+use JustBetter\AkeneoProducts\Jobs\Product\UpdateProductJob;
 use JustBetter\AkeneoProducts\Models\Product;
+use JustBetter\AkeneoProducts\Retrievers\Product\BaseProductRetriever;
 
 class ProcessProducts implements ProcessesProducts
 {
@@ -17,8 +18,7 @@ public function process(): void
             ->where('update', '=', true)
             ->update(['update' => false]);
 
-        /** @var int $retrieveBatchSize */
-        $retrieveBatchSize = config('akeneo-products.retrieve_batch_size');
+        $retrieveBatchSize = BaseProductRetriever::current()->retrieveBatchSize();
 
         // Dispatch jobs for all products that should be retrieved.
         Product::query()
@@ -28,8 +28,7 @@ public function process(): void
             ->pluck('identifier')
             ->each(fn (string $identifier) => RetrieveProductJob::dispatch($identifier));
 
-        /** @var int $updateBatchSize */
-        $updateBatchSize = config('akeneo-products.update_batch_size');
+        $updateBatchSize = BaseProductRetriever::current()->updateBatchSize();
 
         // Dispatch jobs for all products that are should be updated.
         Product::query()
diff --git a/src/Actions/RetrieveProduct.php b/src/Actions/Product/RetrieveProduct.php
similarity index 51%
rename from src/Actions/RetrieveProduct.php
rename to src/Actions/Product/RetrieveProduct.php
index d5ebc56..f7bee90 100644
--- a/src/Actions/RetrieveProduct.php
+++ b/src/Actions/Product/RetrieveProduct.php
@@ -1,16 +1,16 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Actions;
+namespace JustBetter\AkeneoProducts\Actions\Product;
 
-use JustBetter\AkeneoProducts\Contracts\RetrievesProduct;
-use JustBetter\AkeneoProducts\Jobs\SaveProductJob;
-use JustBetter\AkeneoProducts\Retrievers\BaseRetriever;
+use JustBetter\AkeneoProducts\Contracts\Product\RetrievesProduct;
+use JustBetter\AkeneoProducts\Jobs\Product\SaveProductJob;
+use JustBetter\AkeneoProducts\Retrievers\Product\BaseProductRetriever;
 
 class RetrieveProduct implements RetrievesProduct
 {
     public function retrieve(string $identifier): void
     {
-        $product = BaseRetriever::current()->retrieve($identifier);
+        $product = BaseProductRetriever::current()->retrieve($identifier);
 
         if ($product !== null) {
             SaveProductJob::dispatch($product);
diff --git a/src/Actions/SaveProduct.php b/src/Actions/Product/SaveProduct.php
similarity index 89%
rename from src/Actions/SaveProduct.php
rename to src/Actions/Product/SaveProduct.php
index bd4f586..19028f9 100644
--- a/src/Actions/SaveProduct.php
+++ b/src/Actions/Product/SaveProduct.php
@@ -1,8 +1,8 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Actions;
+namespace JustBetter\AkeneoProducts\Actions\Product;
 
-use JustBetter\AkeneoProducts\Contracts\SavesProduct;
+use JustBetter\AkeneoProducts\Contracts\Product\SavesProduct;
 use JustBetter\AkeneoProducts\Data\ProductData;
 use JustBetter\AkeneoProducts\Models\Product;
 
diff --git a/src/Actions/UpdateProduct.php b/src/Actions/Product/UpdateProduct.php
similarity index 83%
rename from src/Actions/UpdateProduct.php
rename to src/Actions/Product/UpdateProduct.php
index b1322d1..6967480 100644
--- a/src/Actions/UpdateProduct.php
+++ b/src/Actions/Product/UpdateProduct.php
@@ -1,9 +1,9 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Actions;
+namespace JustBetter\AkeneoProducts\Actions\Product;
 
 use JustBetter\AkeneoClient\Client\Akeneo;
-use JustBetter\AkeneoProducts\Contracts\UpdatesProduct;
+use JustBetter\AkeneoProducts\Contracts\Product\UpdatesProduct;
 use JustBetter\AkeneoProducts\Models\Product;
 
 class UpdateProduct implements UpdatesProduct
diff --git a/src/Actions/ProductModel/ProcessProductModels.php b/src/Actions/ProductModel/ProcessProductModels.php
new file mode 100644
index 0000000..2966db2
--- /dev/null
+++ b/src/Actions/ProductModel/ProcessProductModels.php
@@ -0,0 +1,45 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Actions\ProductModel;
+
+use JustBetter\AkeneoProducts\Contracts\ProductModel\ProcessesProductModels;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\RetrieveProductModelJob;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\UpdateProductModelJob;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\BaseProductModelRetriever;
+
+class ProcessProductModels implements ProcessesProductModels
+{
+    public function process(): void
+    {
+        // If the product model has to be retrieved again, reset the update state.
+        ProductModel::query()
+            ->where('retrieve', '=', true)
+            ->where('update', '=', true)
+            ->update(['update' => false]);
+
+        $retrieveBatchSize = BaseProductModelRetriever::current()->retrieveBatchSize();
+
+        // Dispatch jobs for all product models that should be retrieved.
+        ProductModel::query()
+            ->scopes('shouldRetrieve')
+            ->limit($retrieveBatchSize)
+            ->get()
+            ->pluck('code')
+            ->each(fn (string $code) => RetrieveProductModelJob::dispatch($code));
+
+        $updateBatchSize = BaseProductModelRetriever::current()->updateBatchSize();
+
+        // Dispatch jobs for all product models that are should be updated.
+        ProductModel::query()
+            ->scopes('shouldUpdate')
+            ->limit($updateBatchSize)
+            ->get()
+            ->each(fn (ProductModel $productModel) => UpdateProductModelJob::dispatch($productModel));
+    }
+
+    public static function bind(): void
+    {
+        app()->singleton(ProcessesProductModels::class, static::class);
+    }
+}
diff --git a/src/Actions/ProductModel/RetrieveProductModel.php b/src/Actions/ProductModel/RetrieveProductModel.php
new file mode 100644
index 0000000..0ed052e
--- /dev/null
+++ b/src/Actions/ProductModel/RetrieveProductModel.php
@@ -0,0 +1,24 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Actions\ProductModel;
+
+use JustBetter\AkeneoProducts\Contracts\ProductModel\RetrievesProductModel;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\SaveProductModelJob;
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\BaseProductModelRetriever;
+
+class RetrieveProductModel implements RetrievesProductModel
+{
+    public function retrieve(string $code): void
+    {
+        $productModel = BaseProductModelRetriever::current()->retrieve($code);
+
+        if ($productModel !== null) {
+            SaveProductModelJob::dispatch($productModel);
+        }
+    }
+
+    public static function bind(): void
+    {
+        app()->singleton(RetrievesProductModel::class, static::class);
+    }
+}
diff --git a/src/Actions/ProductModel/SaveProductModel.php b/src/Actions/ProductModel/SaveProductModel.php
new file mode 100644
index 0000000..efda575
--- /dev/null
+++ b/src/Actions/ProductModel/SaveProductModel.php
@@ -0,0 +1,43 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Actions\ProductModel;
+
+use JustBetter\AkeneoProducts\Contracts\ProductModel\SavesProductModel;
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+
+class SaveProductModel implements SavesProductModel
+{
+    public function save(ProductModelData $productModelData): void
+    {
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()->firstOrCreate(
+            [
+                'code' => $productModelData->code(),
+            ],
+            [
+                'data' => [],
+            ],
+        );
+
+        $data = $productModelData->toArray();
+
+        $encoded = json_encode($data);
+
+        $productModel->data = $data;
+        $productModel->checksum = md5($encoded ?: '');
+        $productModel->retrieved_at = now();
+        $productModel->retrieve = false;
+
+        if (! $productModel->update) {
+            $productModel->update = $productModel->isDirty(['checksum']);
+        }
+
+        $productModel->save();
+    }
+
+    public static function bind(): void
+    {
+        app()->singleton(SavesProductModel::class, static::class);
+    }
+}
diff --git a/src/Actions/ProductModel/UpdateProductModel.php b/src/Actions/ProductModel/UpdateProductModel.php
new file mode 100644
index 0000000..7f87f6e
--- /dev/null
+++ b/src/Actions/ProductModel/UpdateProductModel.php
@@ -0,0 +1,33 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Actions\ProductModel;
+
+use JustBetter\AkeneoClient\Client\Akeneo;
+use JustBetter\AkeneoProducts\Contracts\ProductModel\UpdatesProductModel;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+
+class UpdateProductModel implements UpdatesProductModel
+{
+    public function __construct(
+        protected Akeneo $akeneo
+    ) {
+    }
+
+    public function update(ProductModel $productModel): void
+    {
+        $data = $productModel->data;
+
+        unset($data['code']);
+
+        $this->akeneo->getProductModelApi()->upsert($productModel->code, $data);
+
+        $productModel->modified_at = now();
+        $productModel->update = false;
+        $productModel->save();
+    }
+
+    public static function bind(): void
+    {
+        app()->singleton(UpdatesProductModel::class, static::class);
+    }
+}
diff --git a/src/Commands/ProcessProductsCommand.php b/src/Commands/Product/ProcessProductsCommand.php
similarity index 75%
rename from src/Commands/ProcessProductsCommand.php
rename to src/Commands/Product/ProcessProductsCommand.php
index f03a6bf..bcd3580 100644
--- a/src/Commands/ProcessProductsCommand.php
+++ b/src/Commands/Product/ProcessProductsCommand.php
@@ -1,9 +1,9 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Commands;
+namespace JustBetter\AkeneoProducts\Commands\Product;
 
 use Illuminate\Console\Command;
-use JustBetter\AkeneoProducts\Jobs\ProcessProductsJob;
+use JustBetter\AkeneoProducts\Jobs\Product\ProcessProductsJob;
 
 class ProcessProductsCommand extends Command
 {
diff --git a/src/Commands/RetrieveProductCommand.php b/src/Commands/Product/RetrieveProductCommand.php
similarity index 79%
rename from src/Commands/RetrieveProductCommand.php
rename to src/Commands/Product/RetrieveProductCommand.php
index e3789eb..15de5a6 100644
--- a/src/Commands/RetrieveProductCommand.php
+++ b/src/Commands/Product/RetrieveProductCommand.php
@@ -1,9 +1,9 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Commands;
+namespace JustBetter\AkeneoProducts\Commands\Product;
 
 use Illuminate\Console\Command;
-use JustBetter\AkeneoProducts\Jobs\RetrieveProductJob;
+use JustBetter\AkeneoProducts\Jobs\Product\RetrieveProductJob;
 
 class RetrieveProductCommand extends Command
 {
diff --git a/src/Commands/UpdateProductCommand.php b/src/Commands/Product/UpdateProductCommand.php
similarity index 84%
rename from src/Commands/UpdateProductCommand.php
rename to src/Commands/Product/UpdateProductCommand.php
index c78f7a1..321858c 100644
--- a/src/Commands/UpdateProductCommand.php
+++ b/src/Commands/Product/UpdateProductCommand.php
@@ -1,9 +1,9 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Commands;
+namespace JustBetter\AkeneoProducts\Commands\Product;
 
 use Illuminate\Console\Command;
-use JustBetter\AkeneoProducts\Jobs\UpdateProductJob;
+use JustBetter\AkeneoProducts\Jobs\Product\UpdateProductJob;
 use JustBetter\AkeneoProducts\Models\Product;
 
 class UpdateProductCommand extends Command
diff --git a/src/Commands/ProductModel/ProcessProductModelsCommand.php b/src/Commands/ProductModel/ProcessProductModelsCommand.php
new file mode 100644
index 0000000..0855e61
--- /dev/null
+++ b/src/Commands/ProductModel/ProcessProductModelsCommand.php
@@ -0,0 +1,20 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Commands\ProductModel;
+
+use Illuminate\Console\Command;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\ProcessProductModelsJob;
+
+class ProcessProductModelsCommand extends Command
+{
+    protected $signature = 'akeneo-products:model:process';
+
+    protected $description = 'Process product models, retrieve or update product models when pending.';
+
+    public function handle(): int
+    {
+        ProcessProductModelsJob::dispatch();
+
+        return static::SUCCESS;
+    }
+}
diff --git a/src/Commands/ProductModel/RetrieveProductModelCommand.php b/src/Commands/ProductModel/RetrieveProductModelCommand.php
new file mode 100644
index 0000000..6bd539c
--- /dev/null
+++ b/src/Commands/ProductModel/RetrieveProductModelCommand.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Commands\ProductModel;
+
+use Illuminate\Console\Command;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\RetrieveProductModelJob;
+
+class RetrieveProductModelCommand extends Command
+{
+    protected $signature = 'akeneo-products:model:retrieve {code}';
+
+    protected $description = 'Retrieve a product model by its code';
+
+    public function handle(): int
+    {
+        /** @var string $code */
+        $code = $this->argument('code');
+
+        RetrieveProductModelJob::dispatch($code);
+
+        return static::SUCCESS;
+    }
+}
diff --git a/src/Commands/ProductModel/UpdateProductModelCommand.php b/src/Commands/ProductModel/UpdateProductModelCommand.php
new file mode 100644
index 0000000..22aa9df
--- /dev/null
+++ b/src/Commands/ProductModel/UpdateProductModelCommand.php
@@ -0,0 +1,29 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Commands\ProductModel;
+
+use Illuminate\Console\Command;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\UpdateProductModelJob;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+
+class UpdateProductModelCommand extends Command
+{
+    protected $signature = 'akeneo-products:model:update {code}';
+
+    protected $description = 'Update a product model by its code';
+
+    public function handle(): int
+    {
+        /** @var string $code */
+        $code = $this->argument('code');
+
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()
+            ->where('code', '=', $code)
+            ->firstOrFail();
+
+        UpdateProductModelJob::dispatch($productModel);
+
+        return static::SUCCESS;
+    }
+}
diff --git a/src/Contracts/ProcessesProducts.php b/src/Contracts/Product/ProcessesProducts.php
similarity index 58%
rename from src/Contracts/ProcessesProducts.php
rename to src/Contracts/Product/ProcessesProducts.php
index d5253ce..e029b07 100644
--- a/src/Contracts/ProcessesProducts.php
+++ b/src/Contracts/Product/ProcessesProducts.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Contracts;
+namespace JustBetter\AkeneoProducts\Contracts\Product;
 
 interface ProcessesProducts
 {
diff --git a/src/Contracts/RetrievesProduct.php b/src/Contracts/Product/RetrievesProduct.php
similarity index 63%
rename from src/Contracts/RetrievesProduct.php
rename to src/Contracts/Product/RetrievesProduct.php
index e988bb4..6eaf169 100644
--- a/src/Contracts/RetrievesProduct.php
+++ b/src/Contracts/Product/RetrievesProduct.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Contracts;
+namespace JustBetter\AkeneoProducts\Contracts\Product;
 
 interface RetrievesProduct
 {
diff --git a/src/Contracts/SavesProduct.php b/src/Contracts/Product/SavesProduct.php
similarity index 72%
rename from src/Contracts/SavesProduct.php
rename to src/Contracts/Product/SavesProduct.php
index beedbec..8580444 100644
--- a/src/Contracts/SavesProduct.php
+++ b/src/Contracts/Product/SavesProduct.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Contracts;
+namespace JustBetter\AkeneoProducts\Contracts\Product;
 
 use JustBetter\AkeneoProducts\Data\ProductData;
 
diff --git a/src/Contracts/UpdatesProduct.php b/src/Contracts/Product/UpdatesProduct.php
similarity index 71%
rename from src/Contracts/UpdatesProduct.php
rename to src/Contracts/Product/UpdatesProduct.php
index 817bdda..2a9ede8 100644
--- a/src/Contracts/UpdatesProduct.php
+++ b/src/Contracts/Product/UpdatesProduct.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Contracts;
+namespace JustBetter\AkeneoProducts\Contracts\Product;
 
 use JustBetter\AkeneoProducts\Models\Product;
 
diff --git a/src/Contracts/ProductModel/ProcessesProductModels.php b/src/Contracts/ProductModel/ProcessesProductModels.php
new file mode 100644
index 0000000..bc626ae
--- /dev/null
+++ b/src/Contracts/ProductModel/ProcessesProductModels.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Contracts\ProductModel;
+
+interface ProcessesProductModels
+{
+    public function process(): void;
+}
diff --git a/src/Contracts/ProductModel/RetrievesProductModel.php b/src/Contracts/ProductModel/RetrievesProductModel.php
new file mode 100644
index 0000000..0bcffbd
--- /dev/null
+++ b/src/Contracts/ProductModel/RetrievesProductModel.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Contracts\ProductModel;
+
+interface RetrievesProductModel
+{
+    public function retrieve(string $code): void;
+}
diff --git a/src/Contracts/ProductModel/SavesProductModel.php b/src/Contracts/ProductModel/SavesProductModel.php
new file mode 100644
index 0000000..3be1c44
--- /dev/null
+++ b/src/Contracts/ProductModel/SavesProductModel.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Contracts\ProductModel;
+
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+
+interface SavesProductModel
+{
+    public function save(ProductModelData $productModelData): void;
+}
diff --git a/src/Contracts/ProductModel/UpdatesProductModel.php b/src/Contracts/ProductModel/UpdatesProductModel.php
new file mode 100644
index 0000000..ec0d936
--- /dev/null
+++ b/src/Contracts/ProductModel/UpdatesProductModel.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Contracts\ProductModel;
+
+use JustBetter\AkeneoProducts\Models\ProductModel;
+
+interface UpdatesProductModel
+{
+    public function update(ProductModel $productModel): void;
+}
diff --git a/src/Data/ProductModelData.php b/src/Data/ProductModelData.php
new file mode 100644
index 0000000..b783724
--- /dev/null
+++ b/src/Data/ProductModelData.php
@@ -0,0 +1,33 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Data;
+
+class ProductModelData extends Data
+{
+    public array $rules = [
+        'code' => 'required|string',
+        'values' => 'nullable|array',
+        'family' => 'nullable|string',
+        'categories' => 'nullable|array',
+    ];
+
+    public function code(): string
+    {
+        return $this['code'];
+    }
+
+    public function family(): ?string
+    {
+        return $this['family'];
+    }
+
+    public function categories(): ?array
+    {
+        return $this['categories'];
+    }
+
+    public function values(): array
+    {
+        return $this['values'];
+    }
+}
diff --git a/src/Jobs/ProcessProductsJob.php b/src/Jobs/Product/ProcessProductsJob.php
similarity index 83%
rename from src/Jobs/ProcessProductsJob.php
rename to src/Jobs/Product/ProcessProductsJob.php
index 7ab906b..a1bcef9 100644
--- a/src/Jobs/ProcessProductsJob.php
+++ b/src/Jobs/Product/ProcessProductsJob.php
@@ -1,13 +1,13 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Jobs;
+namespace JustBetter\AkeneoProducts\Jobs\Product;
 
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldBeUnique;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
-use JustBetter\AkeneoProducts\Contracts\ProcessesProducts;
+use JustBetter\AkeneoProducts\Contracts\Product\ProcessesProducts;
 
 class ProcessProductsJob implements ShouldBeUnique, ShouldQueue
 {
diff --git a/src/Jobs/RetrieveProductJob.php b/src/Jobs/Product/RetrieveProductJob.php
similarity index 87%
rename from src/Jobs/RetrieveProductJob.php
rename to src/Jobs/Product/RetrieveProductJob.php
index fa5c7cd..2572062 100644
--- a/src/Jobs/RetrieveProductJob.php
+++ b/src/Jobs/Product/RetrieveProductJob.php
@@ -1,13 +1,13 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Jobs;
+namespace JustBetter\AkeneoProducts\Jobs\Product;
 
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldBeUnique;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
-use JustBetter\AkeneoProducts\Contracts\RetrievesProduct;
+use JustBetter\AkeneoProducts\Contracts\Product\RetrievesProduct;
 
 class RetrieveProductJob implements ShouldBeUnique, ShouldQueue
 {
diff --git a/src/Jobs/SaveProductJob.php b/src/Jobs/Product/SaveProductJob.php
similarity index 88%
rename from src/Jobs/SaveProductJob.php
rename to src/Jobs/Product/SaveProductJob.php
index d856051..214478c 100644
--- a/src/Jobs/SaveProductJob.php
+++ b/src/Jobs/Product/SaveProductJob.php
@@ -1,13 +1,13 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Jobs;
+namespace JustBetter\AkeneoProducts\Jobs\Product;
 
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldBeUnique;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
-use JustBetter\AkeneoProducts\Contracts\SavesProduct;
+use JustBetter\AkeneoProducts\Contracts\Product\SavesProduct;
 use JustBetter\AkeneoProducts\Data\ProductData;
 
 class SaveProductJob implements ShouldBeUnique, ShouldQueue
diff --git a/src/Jobs/UpdateProductJob.php b/src/Jobs/Product/UpdateProductJob.php
similarity index 92%
rename from src/Jobs/UpdateProductJob.php
rename to src/Jobs/Product/UpdateProductJob.php
index b077910..6ca7fd5 100644
--- a/src/Jobs/UpdateProductJob.php
+++ b/src/Jobs/Product/UpdateProductJob.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Jobs;
+namespace JustBetter\AkeneoProducts\Jobs\Product;
 
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldBeUnique;
@@ -8,7 +8,7 @@
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
-use JustBetter\AkeneoProducts\Contracts\UpdatesProduct;
+use JustBetter\AkeneoProducts\Contracts\Product\UpdatesProduct;
 use JustBetter\AkeneoProducts\Models\Product;
 use Throwable;
 
diff --git a/src/Jobs/ProductModel/ProcessProductModelsJob.php b/src/Jobs/ProductModel/ProcessProductModelsJob.php
new file mode 100644
index 0000000..6e47ac0
--- /dev/null
+++ b/src/Jobs/ProductModel/ProcessProductModelsJob.php
@@ -0,0 +1,27 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Jobs\ProductModel;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Broadcasting\ShouldBeUnique;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use JustBetter\AkeneoProducts\Contracts\ProductModel\ProcessesProductModels;
+
+class ProcessProductModelsJob implements ShouldBeUnique, ShouldQueue
+{
+    use Dispatchable;
+    use InteractsWithQueue;
+    use Queueable;
+
+    public function __construct()
+    {
+        $this->onQueue(config('akeneo-products.queue'));
+    }
+
+    public function handle(ProcessesProductModels $processesProductModels): void
+    {
+        $processesProductModels->process();
+    }
+}
diff --git a/src/Jobs/ProductModel/RetrieveProductModelJob.php b/src/Jobs/ProductModel/RetrieveProductModelJob.php
new file mode 100644
index 0000000..7ff5d86
--- /dev/null
+++ b/src/Jobs/ProductModel/RetrieveProductModelJob.php
@@ -0,0 +1,40 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Jobs\ProductModel;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Broadcasting\ShouldBeUnique;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use JustBetter\AkeneoProducts\Contracts\ProductModel\RetrievesProductModel;
+
+class RetrieveProductModelJob implements ShouldBeUnique, ShouldQueue
+{
+    use Dispatchable;
+    use InteractsWithQueue;
+    use Queueable;
+
+    public function __construct(
+        public string $code
+    ) {
+        $this->onQueue(config('akeneo-products.queue'));
+    }
+
+    public function handle(RetrievesProductModel $retrievesProductModel): void
+    {
+        $retrievesProductModel->retrieve($this->code);
+    }
+
+    public function uniqueId(): string
+    {
+        return $this->code;
+    }
+
+    public function tags(): array
+    {
+        return [
+            $this->code,
+        ];
+    }
+}
diff --git a/src/Jobs/ProductModel/SaveProductModelJob.php b/src/Jobs/ProductModel/SaveProductModelJob.php
new file mode 100644
index 0000000..c40aa16
--- /dev/null
+++ b/src/Jobs/ProductModel/SaveProductModelJob.php
@@ -0,0 +1,41 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Jobs\ProductModel;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Broadcasting\ShouldBeUnique;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use JustBetter\AkeneoProducts\Contracts\ProductModel\SavesProductModel;
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+
+class SaveProductModelJob implements ShouldBeUnique, ShouldQueue
+{
+    use Dispatchable;
+    use InteractsWithQueue;
+    use Queueable;
+
+    public function __construct(
+        public ProductModelData $productModelData
+    ) {
+        $this->onQueue(config('akeneo-products.queue'));
+    }
+
+    public function handle(SavesProductModel $savesProductModel): void
+    {
+        $savesProductModel->save($this->productModelData);
+    }
+
+    public function uniqueId(): string
+    {
+        return $this->productModelData->code();
+    }
+
+    public function tags(): array
+    {
+        return [
+            $this->productModelData->code(),
+        ];
+    }
+}
diff --git a/src/Jobs/ProductModel/UpdateProductModelJob.php b/src/Jobs/ProductModel/UpdateProductModelJob.php
new file mode 100644
index 0000000..3176e5d
--- /dev/null
+++ b/src/Jobs/ProductModel/UpdateProductModelJob.php
@@ -0,0 +1,60 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Jobs\ProductModel;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Broadcasting\ShouldBeUnique;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use JustBetter\AkeneoProducts\Contracts\ProductModel\UpdatesProductModel;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use Throwable;
+
+class UpdateProductModelJob implements ShouldBeUnique, ShouldQueue
+{
+    use Dispatchable;
+    use InteractsWithQueue;
+    use Queueable;
+    use SerializesModels;
+
+    public function __construct(
+        public ProductModel $productModel
+    ) {
+        $this->onQueue(config('akeneo-products.queue'));
+    }
+
+    public function handle(UpdatesProductModel $updatesProductModel): void
+    {
+        $updatesProductModel->update($this->productModel);
+    }
+
+    public function uniqueId(): string
+    {
+        return $this->productModel->code;
+    }
+
+    public function tags(): array
+    {
+        return [
+            $this->productModel->code,
+        ];
+    }
+
+    public function failed(Throwable $throwable): void
+    {
+        $this->productModel->failed();
+
+        activity()
+            ->on($this->productModel)
+            ->withProperties([
+                'message' => $throwable->getMessage(),
+                'code' => $throwable->getCode(),
+                'metadata' => [
+                    'level' => 'error',
+                ],
+            ])
+            ->log('Failed to update product model in Akeneo');
+    }
+}
diff --git a/src/Models/Product.php b/src/Models/Product.php
index 9efb763..337fca4 100644
--- a/src/Models/Product.php
+++ b/src/Models/Product.php
@@ -6,6 +6,7 @@
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\SoftDeletes;
 use Illuminate\Support\Carbon;
+use JustBetter\AkeneoProducts\Retrievers\Product\BaseProductRetriever;
 
 /**
  * @property int $id
@@ -60,8 +61,7 @@ public function failed(): void
         $this->fail_count++;
         $this->failed_at = now();
 
-        /** @var int $tries */
-        $tries = config('akeneo-products.tries', 0);
+        $tries = BaseProductRetriever::current()->tries();
 
         if ($tries > 0 && $this->fail_count >= $tries) {
             $this->synchronize = false;
diff --git a/src/Models/ProductModel.php b/src/Models/ProductModel.php
new file mode 100644
index 0000000..c213d60
--- /dev/null
+++ b/src/Models/ProductModel.php
@@ -0,0 +1,72 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Models;
+
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Database\Eloquent\Model;
+use Illuminate\Database\Eloquent\SoftDeletes;
+use Illuminate\Support\Carbon;
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\BaseProductModelRetriever;
+
+/**
+ * @property int $id
+ * @property string $code
+ * @property bool $synchronize
+ * @property bool $retrieve
+ * @property bool $update
+ * @property int $fail_count
+ * @property array $data
+ * @property ?string $checksum
+ * @property ?Carbon $retrieved_at
+ * @property ?Carbon $modified_at
+ * @property ?Carbon $failed_at
+ * @property ?Carbon $updated_at
+ * @property ?Carbon $created_at
+ * @property ?Carbon $deleted_at
+ */
+class ProductModel extends Model
+{
+    use SoftDeletes;
+
+    protected $table = 'akeneo_product_models';
+
+    protected $guarded = [];
+
+    protected $casts = [
+        'synchronize' => 'boolean',
+        'retrieve' => 'boolean',
+        'update' => 'boolean',
+        'retrieved_at' => 'datetime',
+        'modified_at' => 'datetime',
+        'failed_at' => 'datetime',
+        'data' => 'array',
+    ];
+
+    public function scopeShouldRetrieve(Builder $builder): Builder
+    {
+        return $builder
+            ->where('synchronize', '=', true)
+            ->where('retrieve', '=', true);
+    }
+
+    public function scopeShouldUpdate(Builder $builder): Builder
+    {
+        return $builder
+            ->where('synchronize', '=', true)
+            ->where('update', '=', true);
+    }
+
+    public function failed(): void
+    {
+        $this->fail_count++;
+        $this->failed_at = now();
+
+        $tries = BaseProductModelRetriever::current()->tries();
+
+        if ($tries > 0 && $this->fail_count >= $tries) {
+            $this->synchronize = false;
+        }
+
+        $this->save();
+    }
+}
diff --git a/src/Retrievers/BaseRetriever.php b/src/Retrievers/BaseRetriever.php
index 42e331b..3c2d46f 100644
--- a/src/Retrievers/BaseRetriever.php
+++ b/src/Retrievers/BaseRetriever.php
@@ -2,20 +2,29 @@
 
 namespace JustBetter\AkeneoProducts\Retrievers;
 
-use JustBetter\AkeneoProducts\Data\ProductData;
-
 abstract class BaseRetriever
 {
-    abstract public function retrieve(string $identifier): ?ProductData;
+    /* Max tries before a resource sync will automatically be turned off. */
+    protected int $tries = 3;
+
+    /* Amount of resources to be retrieved at once when processing. */
+    protected int $retrieveBatchSize = 100;
 
-    public static function current(): BaseRetriever
+    /* Amount of resources to be updated at once when processing. */
+    protected int $updateBatchSize = 25;
+
+    public function tries(): int
     {
-        /** @var string $class */
-        $class = config('akeneo-products.retriever');
+        return $this->tries;
+    }
 
-        /** @var BaseRetriever $retriever */
-        $retriever = app($class);
+    public function retrieveBatchSize(): int
+    {
+        return $this->retrieveBatchSize;
+    }
 
-        return $retriever;
+    public function updateBatchSize(): int
+    {
+        return $this->updateBatchSize;
     }
 }
diff --git a/src/Retrievers/Product/BaseProductRetriever.php b/src/Retrievers/Product/BaseProductRetriever.php
new file mode 100644
index 0000000..1c8205b
--- /dev/null
+++ b/src/Retrievers/Product/BaseProductRetriever.php
@@ -0,0 +1,22 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Retrievers\Product;
+
+use JustBetter\AkeneoProducts\Data\ProductData;
+use JustBetter\AkeneoProducts\Retrievers\BaseRetriever;
+
+abstract class BaseProductRetriever extends BaseRetriever
+{
+    abstract public function retrieve(string $identifier): ?ProductData;
+
+    public static function current(): static
+    {
+        /** @var string $class */
+        $class = config('akeneo-products.retrievers.product');
+
+        /** @var static $retriever */
+        $retriever = app($class);
+
+        return $retriever;
+    }
+}
diff --git a/src/Retrievers/ProductRetriever.php b/src/Retrievers/Product/ProductRetriever.php
similarity index 73%
rename from src/Retrievers/ProductRetriever.php
rename to src/Retrievers/Product/ProductRetriever.php
index 2dc7a63..9396a4e 100644
--- a/src/Retrievers/ProductRetriever.php
+++ b/src/Retrievers/Product/ProductRetriever.php
@@ -1,11 +1,11 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Retrievers;
+namespace JustBetter\AkeneoProducts\Retrievers\Product;
 
 use JustBetter\AkeneoProducts\Data\ProductData;
 use JustBetter\AkeneoProducts\Exceptions\NotImplementedException;
 
-class ProductRetriever extends BaseRetriever
+class ProductRetriever extends BaseProductRetriever
 {
     public function retrieve(string $identifier): ?ProductData
     {
diff --git a/src/Retrievers/ProductModel/BaseProductModelRetriever.php b/src/Retrievers/ProductModel/BaseProductModelRetriever.php
new file mode 100644
index 0000000..155b747
--- /dev/null
+++ b/src/Retrievers/ProductModel/BaseProductModelRetriever.php
@@ -0,0 +1,22 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Retrievers\ProductModel;
+
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Retrievers\BaseRetriever;
+
+abstract class BaseProductModelRetriever extends BaseRetriever
+{
+    abstract public function retrieve(string $code): ?ProductModelData;
+
+    public static function current(): static
+    {
+        /** @var string $class */
+        $class = config('akeneo-products.retrievers.product_model');
+
+        /** @var static $retriever */
+        $retriever = app($class);
+
+        return $retriever;
+    }
+}
diff --git a/src/Retrievers/ProductModel/ProductModelRetriever.php b/src/Retrievers/ProductModel/ProductModelRetriever.php
new file mode 100644
index 0000000..c57a2ad
--- /dev/null
+++ b/src/Retrievers/ProductModel/ProductModelRetriever.php
@@ -0,0 +1,14 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Retrievers\ProductModel;
+
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Exceptions\NotImplementedException;
+
+class ProductModelRetriever extends BaseProductModelRetriever
+{
+    public function retrieve(string $code): ?ProductModelData
+    {
+        throw new NotImplementedException('Method "'.__FUNCTION__.'" has not been implemented');
+    }
+}
diff --git a/src/ServiceProvider.php b/src/ServiceProvider.php
index 7af0b13..fd55f86 100644
--- a/src/ServiceProvider.php
+++ b/src/ServiceProvider.php
@@ -10,13 +10,20 @@
 use JustBetter\AkeneoProducts\Actions\Akeneo\GetLocales;
 use JustBetter\AkeneoProducts\Actions\Akeneo\GetScopes;
 use JustBetter\AkeneoProducts\Actions\Akeneo\ResolveAttributeOption;
-use JustBetter\AkeneoProducts\Actions\ProcessProducts;
-use JustBetter\AkeneoProducts\Actions\RetrieveProduct;
-use JustBetter\AkeneoProducts\Actions\SaveProduct;
-use JustBetter\AkeneoProducts\Actions\UpdateProduct;
-use JustBetter\AkeneoProducts\Commands\ProcessProductsCommand;
-use JustBetter\AkeneoProducts\Commands\RetrieveProductCommand;
-use JustBetter\AkeneoProducts\Commands\UpdateProductCommand;
+use JustBetter\AkeneoProducts\Actions\Product\ProcessProducts;
+use JustBetter\AkeneoProducts\Actions\Product\RetrieveProduct;
+use JustBetter\AkeneoProducts\Actions\Product\SaveProduct;
+use JustBetter\AkeneoProducts\Actions\Product\UpdateProduct;
+use JustBetter\AkeneoProducts\Actions\ProductModel\ProcessProductModels;
+use JustBetter\AkeneoProducts\Actions\ProductModel\RetrieveProductModel;
+use JustBetter\AkeneoProducts\Actions\ProductModel\SaveProductModel;
+use JustBetter\AkeneoProducts\Actions\ProductModel\UpdateProductModel;
+use JustBetter\AkeneoProducts\Commands\Product\ProcessProductsCommand;
+use JustBetter\AkeneoProducts\Commands\Product\RetrieveProductCommand;
+use JustBetter\AkeneoProducts\Commands\Product\UpdateProductCommand;
+use JustBetter\AkeneoProducts\Commands\ProductModel\ProcessProductModelsCommand;
+use JustBetter\AkeneoProducts\Commands\ProductModel\RetrieveProductModelCommand;
+use JustBetter\AkeneoProducts\Commands\ProductModel\UpdateProductModelCommand;
 
 class ServiceProvider extends BaseServiceProvider
 {
@@ -36,11 +43,19 @@ protected function registerConfig(): static
 
     protected function registerActions(): static
     {
+        // Products
         ProcessProducts::bind();
         RetrieveProduct::bind();
         SaveProduct::bind();
         UpdateProduct::bind();
 
+        // Product models
+        ProcessProductModels::bind();
+        RetrieveProductModel::bind();
+        SaveProductModel::bind();
+        UpdateProductModel::bind();
+
+        // Akeneo
         CreateAttributeOption::bind();
         FormatAttributeValues::bind();
         GetAttribute::bind();
@@ -80,9 +95,15 @@ protected function bootCommands(): static
     {
         if ($this->app->runningInConsole()) {
             $this->commands([
+                // Product
                 ProcessProductsCommand::class,
                 RetrieveProductCommand::class,
                 UpdateProductCommand::class,
+
+                // Product models
+                ProcessProductModelsCommand::class,
+                RetrieveProductModelCommand::class,
+                UpdateProductModelCommand::class,
             ]);
         }
 
diff --git a/tests/Actions/ProcessProductsTest.php b/tests/Actions/Product/ProcessProductsTest.php
similarity index 82%
rename from tests/Actions/ProcessProductsTest.php
rename to tests/Actions/Product/ProcessProductsTest.php
index 94ea950..b6eca21 100644
--- a/tests/Actions/ProcessProductsTest.php
+++ b/tests/Actions/Product/ProcessProductsTest.php
@@ -1,12 +1,13 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Actions;
+namespace JustBetter\AkeneoProducts\Tests\Actions\Product;
 
 use Illuminate\Support\Facades\Bus;
-use JustBetter\AkeneoProducts\Actions\ProcessProducts;
-use JustBetter\AkeneoProducts\Jobs\RetrieveProductJob;
-use JustBetter\AkeneoProducts\Jobs\UpdateProductJob;
+use JustBetter\AkeneoProducts\Actions\Product\ProcessProducts;
+use JustBetter\AkeneoProducts\Jobs\Product\RetrieveProductJob;
+use JustBetter\AkeneoProducts\Jobs\Product\UpdateProductJob;
 use JustBetter\AkeneoProducts\Models\Product;
+use JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\Product\ProductRetriever;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
 class ProcessProductsTest extends TestCase
@@ -16,8 +17,7 @@ public function it_can_process_products(): void
     {
         Bus::fake();
 
-        config()->set('akeneo-products.retrieve_batch_size', 2);
-        config()->set('akeneo-products.update_batch_size', 2);
+        config()->set('akeneo-products.retrievers.product', ProductRetriever::class);
 
         Product::query()->insert([
             [
diff --git a/tests/Actions/RetrieveProductTest.php b/tests/Actions/Product/RetrieveProductTest.php
similarity index 55%
rename from tests/Actions/RetrieveProductTest.php
rename to tests/Actions/Product/RetrieveProductTest.php
index 7b795d6..05d1a92 100644
--- a/tests/Actions/RetrieveProductTest.php
+++ b/tests/Actions/Product/RetrieveProductTest.php
@@ -1,11 +1,11 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Actions;
+namespace JustBetter\AkeneoProducts\Tests\Actions\Product;
 
 use Illuminate\Support\Facades\Bus;
-use JustBetter\AkeneoProducts\Actions\RetrieveProduct;
-use JustBetter\AkeneoProducts\Jobs\SaveProductJob;
-use JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\TestRetriever;
+use JustBetter\AkeneoProducts\Actions\Product\RetrieveProduct;
+use JustBetter\AkeneoProducts\Jobs\Product\SaveProductJob;
+use JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\Product\ProductRetriever;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
 class RetrieveProductTest extends TestCase
@@ -15,7 +15,7 @@ public function it_can_retrieve_products(): void
     {
         Bus::fake();
 
-        config()->set('akeneo-products.retriever', TestRetriever::class);
+        config()->set('akeneo-products.retrievers.product', ProductRetriever::class);
 
         /** @var RetrieveProduct $action */
         $action = app(RetrieveProduct::class);
diff --git a/tests/Actions/SaveProductTest.php b/tests/Actions/Product/SaveProductTest.php
similarity index 95%
rename from tests/Actions/SaveProductTest.php
rename to tests/Actions/Product/SaveProductTest.php
index bffe3f7..d5947ae 100644
--- a/tests/Actions/SaveProductTest.php
+++ b/tests/Actions/Product/SaveProductTest.php
@@ -1,8 +1,8 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Actions;
+namespace JustBetter\AkeneoProducts\Tests\Actions\Product;
 
-use JustBetter\AkeneoProducts\Actions\SaveProduct;
+use JustBetter\AkeneoProducts\Actions\Product\SaveProduct;
 use JustBetter\AkeneoProducts\Data\ProductData;
 use JustBetter\AkeneoProducts\Models\Product;
 use JustBetter\AkeneoProducts\Tests\TestCase;
diff --git a/tests/Actions/UpdateProductTest.php b/tests/Actions/Product/UpdateProductTest.php
similarity index 92%
rename from tests/Actions/UpdateProductTest.php
rename to tests/Actions/Product/UpdateProductTest.php
index 8b4aa44..e56202a 100644
--- a/tests/Actions/UpdateProductTest.php
+++ b/tests/Actions/Product/UpdateProductTest.php
@@ -1,11 +1,11 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Actions;
+namespace JustBetter\AkeneoProducts\Tests\Actions\Product;
 
 use Illuminate\Http\Client\Request;
 use Illuminate\Support\Facades\Http;
 use JustBetter\AkeneoClient\Client\Akeneo;
-use JustBetter\AkeneoProducts\Actions\UpdateProduct;
+use JustBetter\AkeneoProducts\Actions\Product\UpdateProduct;
 use JustBetter\AkeneoProducts\Models\Product;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
diff --git a/tests/Actions/ProductModel/ProcessProductModelsTest.php b/tests/Actions/ProductModel/ProcessProductModelsTest.php
new file mode 100644
index 0000000..42f3aa8
--- /dev/null
+++ b/tests/Actions/ProductModel/ProcessProductModelsTest.php
@@ -0,0 +1,74 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Actions\ProductModel;
+
+use Illuminate\Support\Facades\Bus;
+use JustBetter\AkeneoProducts\Actions\ProductModel\ProcessProductModels;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\RetrieveProductModelJob;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\UpdateProductModelJob;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\ProductModel\ProductModelRetriever;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class ProcessProductModelsTest extends TestCase
+{
+    /** @test */
+    public function it_can_process_product_models(): void
+    {
+        Bus::fake();
+
+        config()->set('akeneo-products.retrievers.product_model', ProductModelRetriever::class);
+
+        ProductModel::query()->insert([
+            [
+                'code' => 'code-1',
+                'synchronize' => false,
+                'retrieve' => true,
+                'update' => false,
+                'data' => '{}',
+            ],
+            [
+                'code' => 'code-2',
+                'synchronize' => true,
+                'retrieve' => true,
+                'update' => false,
+                'data' => '{}',
+            ],
+            [
+                'code' => 'code-3',
+                'synchronize' => true,
+                'retrieve' => false,
+                'update' => false,
+                'data' => '{}',
+            ],
+            [
+                'code' => 'code-4',
+                'synchronize' => true,
+                'retrieve' => false,
+                'update' => true,
+                'data' => '{}',
+            ],
+            [
+                'code' => 'code-5',
+                'synchronize' => true,
+                'retrieve' => false,
+                'update' => true,
+                'data' => '{}',
+            ],
+            [
+                'code' => 'code-6',
+                'synchronize' => true,
+                'retrieve' => false,
+                'update' => true,
+                'data' => '{}',
+            ],
+        ]);
+
+        /** @var ProcessProductModels $action */
+        $action = app(ProcessProductModels::class);
+        $action->process();
+
+        Bus::assertDispatched(RetrieveProductModelJob::class, 1);
+        Bus::assertDispatched(UpdateProductModelJob::class, 2);
+    }
+}
diff --git a/tests/Actions/ProductModel/RetrieveProductModelTest.php b/tests/Actions/ProductModel/RetrieveProductModelTest.php
new file mode 100644
index 0000000..9a96981
--- /dev/null
+++ b/tests/Actions/ProductModel/RetrieveProductModelTest.php
@@ -0,0 +1,26 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Actions\ProductModel;
+
+use Illuminate\Support\Facades\Bus;
+use JustBetter\AkeneoProducts\Actions\ProductModel\RetrieveProductModel;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\SaveProductModelJob;
+use JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\ProductModel\ProductModelRetriever;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class RetrieveProductModelTest extends TestCase
+{
+    /** @test */
+    public function it_can_retrieve_product_models(): void
+    {
+        Bus::fake();
+
+        config()->set('akeneo-products.retrievers.product_model', ProductModelRetriever::class);
+
+        /** @var RetrieveProductModel $action */
+        $action = app(RetrieveProductModel::class);
+        $action->retrieve('code');
+
+        Bus::assertDispatched(SaveProductModelJob::class);
+    }
+}
diff --git a/tests/Actions/ProductModel/SaveProductModelTest.php b/tests/Actions/ProductModel/SaveProductModelTest.php
new file mode 100644
index 0000000..faa0125
--- /dev/null
+++ b/tests/Actions/ProductModel/SaveProductModelTest.php
@@ -0,0 +1,104 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Actions\ProductModel;
+
+use JustBetter\AkeneoProducts\Actions\ProductModel\SaveProductModel;
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class SaveProductModelTest extends TestCase
+{
+    /** @test */
+    public function it_can_save_product_models(): void
+    {
+        $productModelData = ProductModelData::of([
+            'code' => 'code',
+            'values' => [
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+                'color' => [
+                    [
+                        'locale' => null,
+                        'scope' => null,
+                        'data' => 'purple',
+                    ],
+                ],
+            ],
+        ]);
+
+        /** @var SaveProductModel $action */
+        $action = app(SaveProductModel::class);
+        $action->save($productModelData);
+
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()
+            ->where('code', '=', 'code')
+            ->firstOrFail();
+
+        $this->assertTrue($productModel->update);
+
+        $productModel->update = false;
+        $productModel->save();
+
+        $productModelData = ProductModelData::of([
+            'code' => 'code',
+            'values' => [
+                'color' => [
+                    [
+                        'locale' => null,
+                        'scope' => null,
+                        'data' => 'purple',
+                    ],
+                ],
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+            ],
+        ]);
+
+        $action->save($productModelData);
+
+        $productModel->refresh();
+
+        $this->assertTrue($productModel->update);
+
+        $productModel->update = false;
+        $productModel->save();
+
+        $productModelData = ProductModelData::of([
+            'code' => 'code',
+            'values' => [
+                'color' => [
+                    [
+                        'locale' => null,
+                        'scope' => null,
+                        'data' => 'purple',
+                    ],
+                ],
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+            ],
+        ]);
+
+        $action->save($productModelData);
+
+        $productModel->refresh();
+
+        $this->assertFalse($productModel->update);
+    }
+}
diff --git a/tests/Actions/ProductModel/UpdateProductModelTest.php b/tests/Actions/ProductModel/UpdateProductModelTest.php
new file mode 100644
index 0000000..885c52f
--- /dev/null
+++ b/tests/Actions/ProductModel/UpdateProductModelTest.php
@@ -0,0 +1,58 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Actions\ProductModel;
+
+use Illuminate\Http\Client\Request;
+use Illuminate\Support\Facades\Http;
+use JustBetter\AkeneoClient\Client\Akeneo;
+use JustBetter\AkeneoProducts\Actions\ProductModel\UpdateProductModel;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class UpdateProductModelTest extends TestCase
+{
+    /** @test */
+    public function it_can_update_product_models(): void
+    {
+        Akeneo::fake();
+        Http::fake();
+
+        $payload = [
+            'code' => 'code',
+            'values' => [
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+            ],
+        ];
+
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()->create([
+            'code' => 'code',
+            'data' => $payload,
+        ]);
+
+        /** @var UpdateProductModel $action */
+        $action = app(UpdateProductModel::class);
+        $action->update($productModel);
+
+        Http::assertSent(function (Request $request) use ($payload): bool {
+            if ($request->url() === 'akeneo/api/oauth/v1/token') {
+                return true;
+            }
+
+            if ($request->url() === 'akeneo/api/rest/v1/product-models/code') {
+                return $request->data() === $payload;
+            }
+
+            return false;
+        });
+
+        $this->assertNotNull($productModel->modified_at);
+        $this->assertFalse($productModel->update);
+    }
+}
diff --git a/tests/Commands/ProcessProductsCommandTest.php b/tests/Commands/Product/ProcessProductsCommandTest.php
similarity index 73%
rename from tests/Commands/ProcessProductsCommandTest.php
rename to tests/Commands/Product/ProcessProductsCommandTest.php
index 20cc0be..dfad7ce 100644
--- a/tests/Commands/ProcessProductsCommandTest.php
+++ b/tests/Commands/Product/ProcessProductsCommandTest.php
@@ -1,11 +1,11 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Commands;
+namespace JustBetter\AkeneoProducts\Tests\Commands\Product;
 
 use Illuminate\Support\Facades\Bus;
 use Illuminate\Testing\PendingCommand;
-use JustBetter\AkeneoProducts\Commands\ProcessProductsCommand;
-use JustBetter\AkeneoProducts\Jobs\ProcessProductsJob;
+use JustBetter\AkeneoProducts\Commands\Product\ProcessProductsCommand;
+use JustBetter\AkeneoProducts\Jobs\Product\ProcessProductsJob;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
 class ProcessProductsCommandTest extends TestCase
diff --git a/tests/Commands/RetrieveProductCommandTest.php b/tests/Commands/Product/RetrieveProductCommandTest.php
similarity index 74%
rename from tests/Commands/RetrieveProductCommandTest.php
rename to tests/Commands/Product/RetrieveProductCommandTest.php
index e9c5c34..a68a684 100644
--- a/tests/Commands/RetrieveProductCommandTest.php
+++ b/tests/Commands/Product/RetrieveProductCommandTest.php
@@ -1,11 +1,11 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Commands;
+namespace JustBetter\AkeneoProducts\Tests\Commands\Product;
 
 use Illuminate\Support\Facades\Bus;
 use Illuminate\Testing\PendingCommand;
-use JustBetter\AkeneoProducts\Commands\RetrieveProductCommand;
-use JustBetter\AkeneoProducts\Jobs\RetrieveProductJob;
+use JustBetter\AkeneoProducts\Commands\Product\RetrieveProductCommand;
+use JustBetter\AkeneoProducts\Jobs\Product\RetrieveProductJob;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
 class RetrieveProductCommandTest extends TestCase
diff --git a/tests/Commands/UpdateProductCommandTest.php b/tests/Commands/Product/UpdateProductCommandTest.php
similarity index 80%
rename from tests/Commands/UpdateProductCommandTest.php
rename to tests/Commands/Product/UpdateProductCommandTest.php
index cc53d47..0920804 100644
--- a/tests/Commands/UpdateProductCommandTest.php
+++ b/tests/Commands/Product/UpdateProductCommandTest.php
@@ -1,11 +1,11 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Commands;
+namespace JustBetter\AkeneoProducts\Tests\Commands\Product;
 
 use Illuminate\Support\Facades\Bus;
 use Illuminate\Testing\PendingCommand;
-use JustBetter\AkeneoProducts\Commands\UpdateProductCommand;
-use JustBetter\AkeneoProducts\Jobs\UpdateProductJob;
+use JustBetter\AkeneoProducts\Commands\Product\UpdateProductCommand;
+use JustBetter\AkeneoProducts\Jobs\Product\UpdateProductJob;
 use JustBetter\AkeneoProducts\Models\Product;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
diff --git a/tests/Commands/ProductModel/ProcessProductModelsCommandTest.php b/tests/Commands/ProductModel/ProcessProductModelsCommandTest.php
new file mode 100644
index 0000000..07be060
--- /dev/null
+++ b/tests/Commands/ProductModel/ProcessProductModelsCommandTest.php
@@ -0,0 +1,27 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Commands\ProductModel;
+
+use Illuminate\Support\Facades\Bus;
+use Illuminate\Testing\PendingCommand;
+use JustBetter\AkeneoProducts\Commands\ProductModel\ProcessProductModelsCommand;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\ProcessProductModelsJob;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class ProcessProductModelsCommandTest extends TestCase
+{
+    /** @test */
+    public function it_can_dispatch_jobs(): void
+    {
+        Bus::fake();
+
+        /** @var PendingCommand $artisan */
+        $artisan = $this->artisan(ProcessProductModelsCommand::class);
+
+        $artisan
+            ->assertSuccessful()
+            ->run();
+
+        Bus::assertDispatched(ProcessProductModelsJob::class);
+    }
+}
diff --git a/tests/Commands/ProductModel/RetrieveProductModelCommandTest.php b/tests/Commands/ProductModel/RetrieveProductModelCommandTest.php
new file mode 100644
index 0000000..c0e9ce3
--- /dev/null
+++ b/tests/Commands/ProductModel/RetrieveProductModelCommandTest.php
@@ -0,0 +1,29 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Commands\ProductModel;
+
+use Illuminate\Support\Facades\Bus;
+use Illuminate\Testing\PendingCommand;
+use JustBetter\AkeneoProducts\Commands\ProductModel\RetrieveProductModelCommand;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\RetrieveProductModelJob;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class RetrieveProductModelCommandTest extends TestCase
+{
+    /** @test */
+    public function it_can_dispatch_jobs(): void
+    {
+        Bus::fake();
+
+        /** @var PendingCommand $artisan */
+        $artisan = $this->artisan(RetrieveProductModelCommand::class, [
+            'code' => 'code',
+        ]);
+
+        $artisan
+            ->assertSuccessful()
+            ->run();
+
+        Bus::assertDispatched(RetrieveProductModelJob::class);
+    }
+}
diff --git a/tests/Commands/ProductModel/UpdateProductModelCommandTest.php b/tests/Commands/ProductModel/UpdateProductModelCommandTest.php
new file mode 100644
index 0000000..f23300b
--- /dev/null
+++ b/tests/Commands/ProductModel/UpdateProductModelCommandTest.php
@@ -0,0 +1,36 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Commands\ProductModel;
+
+use Illuminate\Support\Facades\Bus;
+use Illuminate\Testing\PendingCommand;
+use JustBetter\AkeneoProducts\Commands\ProductModel\UpdateProductModelCommand;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\UpdateProductModelJob;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class UpdateProductModelCommandTest extends TestCase
+{
+    /** @test */
+    public function it_can_dispatch_jobs(): void
+    {
+        Bus::fake();
+
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()->create([
+            'code' => 'code',
+            'data' => [],
+        ]);
+
+        /** @var PendingCommand $artisan */
+        $artisan = $this->artisan(UpdateProductModelCommand::class, [
+            'code' => $productModel->code,
+        ]);
+
+        $artisan
+            ->assertSuccessful()
+            ->run();
+
+        Bus::assertDispatched(UpdateProductModelJob::class);
+    }
+}
diff --git a/tests/Data/ProductModelDataTest.php b/tests/Data/ProductModelDataTest.php
new file mode 100644
index 0000000..d1694b9
--- /dev/null
+++ b/tests/Data/ProductModelDataTest.php
@@ -0,0 +1,43 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Data;
+
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class ProductModelDataTest extends TestCase
+{
+    /** @test */
+    public function it_can_interact_with_product_model_data(): void
+    {
+        $productModelData = ProductModelData::of([
+            'code' => 'code',
+            'family' => 'family',
+            'categories' => [
+                'category',
+            ],
+            'values' => [
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+            ],
+        ]);
+
+        $this->assertEquals('code', $productModelData->code());
+        $this->assertEquals('family', $productModelData->family());
+        $this->assertEquals(['category'], $productModelData->categories());
+        $this->assertEquals([
+            'name' => [
+                [
+                    'locale' => 'nl_NL',
+                    'scope' => 'ecommerce',
+                    'data' => 'Ziggy',
+                ],
+            ],
+        ], $productModelData->values());
+    }
+}
diff --git a/tests/Fakes/Retrievers/TestRetriever.php b/tests/Fakes/Retrievers/Product/ProductRetriever.php
similarity index 61%
rename from tests/Fakes/Retrievers/TestRetriever.php
rename to tests/Fakes/Retrievers/Product/ProductRetriever.php
index 378f0c8..062093c 100644
--- a/tests/Fakes/Retrievers/TestRetriever.php
+++ b/tests/Fakes/Retrievers/Product/ProductRetriever.php
@@ -1,12 +1,18 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Fakes\Retrievers;
+namespace JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\Product;
 
 use JustBetter\AkeneoProducts\Data\ProductData;
-use JustBetter\AkeneoProducts\Retrievers\BaseRetriever;
+use JustBetter\AkeneoProducts\Retrievers\Product\BaseProductRetriever;
 
-class TestRetriever extends BaseRetriever
+class ProductRetriever extends BaseProductRetriever
 {
+    protected int $tries = 2;
+
+    protected int $retrieveBatchSize = 2;
+
+    protected int $updateBatchSize = 2;
+
     public function retrieve(string $identifier): ?ProductData
     {
         return ProductData::of([
diff --git a/tests/Fakes/Retrievers/ProductModel/ProductModelRetriever.php b/tests/Fakes/Retrievers/ProductModel/ProductModelRetriever.php
new file mode 100644
index 0000000..31d19fa
--- /dev/null
+++ b/tests/Fakes/Retrievers/ProductModel/ProductModelRetriever.php
@@ -0,0 +1,31 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\ProductModel;
+
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\BaseProductModelRetriever;
+
+class ProductModelRetriever extends BaseProductModelRetriever
+{
+    protected int $tries = 2;
+
+    protected int $retrieveBatchSize = 2;
+
+    protected int $updateBatchSize = 2;
+
+    public function retrieve(string $code): ?ProductModelData
+    {
+        return ProductModelData::of([
+            'code' => 'code',
+            'values' => [
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+            ],
+        ]);
+    }
+}
diff --git a/tests/Jobs/ProcessProductsJobTest.php b/tests/Jobs/Product/ProcessProductsJobTest.php
similarity index 71%
rename from tests/Jobs/ProcessProductsJobTest.php
rename to tests/Jobs/Product/ProcessProductsJobTest.php
index d9f3a69..e9326c2 100644
--- a/tests/Jobs/ProcessProductsJobTest.php
+++ b/tests/Jobs/Product/ProcessProductsJobTest.php
@@ -1,9 +1,9 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Jobs;
+namespace JustBetter\AkeneoProducts\Tests\Jobs\Product;
 
-use JustBetter\AkeneoProducts\Contracts\ProcessesProducts;
-use JustBetter\AkeneoProducts\Jobs\ProcessProductsJob;
+use JustBetter\AkeneoProducts\Contracts\Product\ProcessesProducts;
+use JustBetter\AkeneoProducts\Jobs\Product\ProcessProductsJob;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 use Mockery\MockInterface;
 
diff --git a/tests/Jobs/RetrieveProductJobTest.php b/tests/Jobs/Product/RetrieveProductJobTest.php
similarity index 80%
rename from tests/Jobs/RetrieveProductJobTest.php
rename to tests/Jobs/Product/RetrieveProductJobTest.php
index 1815e18..60058ac 100644
--- a/tests/Jobs/RetrieveProductJobTest.php
+++ b/tests/Jobs/Product/RetrieveProductJobTest.php
@@ -1,9 +1,9 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Jobs;
+namespace JustBetter\AkeneoProducts\Tests\Jobs\Product;
 
-use JustBetter\AkeneoProducts\Contracts\RetrievesProduct;
-use JustBetter\AkeneoProducts\Jobs\RetrieveProductJob;
+use JustBetter\AkeneoProducts\Contracts\Product\RetrievesProduct;
+use JustBetter\AkeneoProducts\Jobs\Product\RetrieveProductJob;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 use Mockery\MockInterface;
 
diff --git a/tests/Jobs/SaveProductJobTest.php b/tests/Jobs/Product/SaveProductJobTest.php
similarity index 89%
rename from tests/Jobs/SaveProductJobTest.php
rename to tests/Jobs/Product/SaveProductJobTest.php
index 3c864ce..9e61072 100644
--- a/tests/Jobs/SaveProductJobTest.php
+++ b/tests/Jobs/Product/SaveProductJobTest.php
@@ -1,10 +1,10 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Jobs;
+namespace JustBetter\AkeneoProducts\Tests\Jobs\Product;
 
-use JustBetter\AkeneoProducts\Contracts\SavesProduct;
+use JustBetter\AkeneoProducts\Contracts\Product\SavesProduct;
 use JustBetter\AkeneoProducts\Data\ProductData;
-use JustBetter\AkeneoProducts\Jobs\SaveProductJob;
+use JustBetter\AkeneoProducts\Jobs\Product\SaveProductJob;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 use Mockery\MockInterface;
 
diff --git a/tests/Jobs/UpdateProductJobTest.php b/tests/Jobs/Product/UpdateProductJobTest.php
similarity index 89%
rename from tests/Jobs/UpdateProductJobTest.php
rename to tests/Jobs/Product/UpdateProductJobTest.php
index 4c71f4d..7927e9a 100644
--- a/tests/Jobs/UpdateProductJobTest.php
+++ b/tests/Jobs/Product/UpdateProductJobTest.php
@@ -1,10 +1,10 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Jobs;
+namespace JustBetter\AkeneoProducts\Tests\Jobs\Product;
 
 use Exception;
-use JustBetter\AkeneoProducts\Contracts\UpdatesProduct;
-use JustBetter\AkeneoProducts\Jobs\UpdateProductJob;
+use JustBetter\AkeneoProducts\Contracts\Product\UpdatesProduct;
+use JustBetter\AkeneoProducts\Jobs\Product\UpdateProductJob;
 use JustBetter\AkeneoProducts\Models\Product;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 use Mockery\MockInterface;
diff --git a/tests/Jobs/ProductModel/ProcessProductModelsJobTest.php b/tests/Jobs/ProductModel/ProcessProductModelsJobTest.php
new file mode 100644
index 0000000..18e9dfc
--- /dev/null
+++ b/tests/Jobs/ProductModel/ProcessProductModelsJobTest.php
@@ -0,0 +1,24 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Jobs\ProductModel;
+
+use JustBetter\AkeneoProducts\Contracts\ProductModel\ProcessesProductModels;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\ProcessProductModelsJob;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+use Mockery\MockInterface;
+
+class ProcessProductModelsJobTest extends TestCase
+{
+    /** @test */
+    public function it_can_process_product_models(): void
+    {
+        $this->mock(ProcessesProductModels::class, function (MockInterface $mock): void {
+            $mock
+                ->shouldReceive('process')
+                ->once()
+                ->andReturn();
+        });
+
+        ProcessProductModelsJob::dispatch();
+    }
+}
diff --git a/tests/Jobs/ProductModel/RetrieveProductModelJobTest.php b/tests/Jobs/ProductModel/RetrieveProductModelJobTest.php
new file mode 100644
index 0000000..e44d877
--- /dev/null
+++ b/tests/Jobs/ProductModel/RetrieveProductModelJobTest.php
@@ -0,0 +1,34 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Jobs\ProductModel;
+
+use JustBetter\AkeneoProducts\Contracts\ProductModel\RetrievesProductModel;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\RetrieveProductModelJob;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+use Mockery\MockInterface;
+
+class RetrieveProductModelJobTest extends TestCase
+{
+    /** @test */
+    public function it_can_retrieve_product_models(): void
+    {
+        $this->mock(RetrievesProductModel::class, function (MockInterface $mock): void {
+            $mock
+                ->shouldReceive('retrieve')
+                ->with('code')
+                ->once()
+                ->andReturn();
+        });
+
+        RetrieveProductModelJob::dispatch('code');
+    }
+
+    /** @test */
+    public function it_has_correct_tags_and_unique_id(): void
+    {
+        $job = new RetrieveProductModelJob('code');
+
+        $this->assertEquals(['code'], $job->tags());
+        $this->assertEquals('code', $job->uniqueId());
+    }
+}
diff --git a/tests/Jobs/ProductModel/SaveProductModelJobTest.php b/tests/Jobs/ProductModel/SaveProductModelJobTest.php
new file mode 100644
index 0000000..20ae5a3
--- /dev/null
+++ b/tests/Jobs/ProductModel/SaveProductModelJobTest.php
@@ -0,0 +1,60 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Jobs\ProductModel;
+
+use JustBetter\AkeneoProducts\Contracts\ProductModel\SavesProductModel;
+use JustBetter\AkeneoProducts\Data\ProductModelData;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\SaveProductModelJob;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+use Mockery\MockInterface;
+
+class SaveProductModelJobTest extends TestCase
+{
+    /** @test */
+    public function it_can_save_product_models(): void
+    {
+        $productModelData = ProductModelData::of([
+            'code' => 'code',
+            'values' => [
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+            ],
+        ]);
+
+        $this->mock(SavesProductModel::class, function (MockInterface $mock): void {
+            $mock
+                ->shouldReceive('save')
+                ->once()
+                ->andReturn();
+        });
+
+        SaveProductModelJob::dispatch($productModelData);
+    }
+
+    /** @test */
+    public function it_has_correct_tags_and_unique_id(): void
+    {
+        $productModelData = ProductModelData::of([
+            'code' => 'code',
+            'values' => [
+                'name' => [
+                    [
+                        'locale' => 'nl_NL',
+                        'scope' => 'ecommerce',
+                        'data' => 'Ziggy',
+                    ],
+                ],
+            ],
+        ]);
+
+        $job = new SaveProductModelJob($productModelData);
+
+        $this->assertEquals(['code'], $job->tags());
+        $this->assertEquals('code', $job->uniqueId());
+    }
+}
diff --git a/tests/Jobs/ProductModel/UpdateProductModelJobTest.php b/tests/Jobs/ProductModel/UpdateProductModelJobTest.php
new file mode 100644
index 0000000..a88ec5b
--- /dev/null
+++ b/tests/Jobs/ProductModel/UpdateProductModelJobTest.php
@@ -0,0 +1,62 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Jobs\ProductModel;
+
+use Exception;
+use JustBetter\AkeneoProducts\Contracts\ProductModel\UpdatesProductModel;
+use JustBetter\AkeneoProducts\Jobs\ProductModel\UpdateProductModelJob;
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+use Mockery\MockInterface;
+
+class UpdateProductModelJobTest extends TestCase
+{
+    /** @test */
+    public function it_can_update_product_models(): void
+    {
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()->create([
+            'code' => 'code',
+            'data' => [],
+        ]);
+
+        $this->mock(UpdatesProductModel::class, function (MockInterface $mock): void {
+            $mock
+                ->shouldReceive('update')
+                ->once()
+                ->andReturn();
+        });
+
+        UpdateProductModelJob::dispatch($productModel);
+    }
+
+    /** @test */
+    public function it_can_fail(): void
+    {
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()->create([
+            'code' => 'code',
+            'data' => [],
+        ]);
+
+        $job = new UpdateProductModelJob($productModel);
+        $job->failed(new Exception);
+
+        $this->assertNotNull($productModel->failed_at);
+    }
+
+    /** @test */
+    public function it_has_correct_tags_and_unique_id(): void
+    {
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()->create([
+            'code' => 'code',
+            'data' => [],
+        ]);
+
+        $job = new UpdateProductModelJob($productModel);
+
+        $this->assertEquals(['code'], $job->tags());
+        $this->assertEquals('code', $job->uniqueId());
+    }
+}
diff --git a/tests/Models/ProductModelTest.php b/tests/Models/ProductModelTest.php
new file mode 100644
index 0000000..a3eb826
--- /dev/null
+++ b/tests/Models/ProductModelTest.php
@@ -0,0 +1,35 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Models;
+
+use JustBetter\AkeneoProducts\Models\ProductModel;
+use JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\ProductModel\ProductModelRetriever;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class ProductModelTest extends TestCase
+{
+    /** @test */
+    public function it_can_stop_the_synchronization(): void
+    {
+        config()->set('akeneo-products.retrievers.product_model', ProductModelRetriever::class);
+
+        /** @var ProductModel $productModel */
+        $productModel = ProductModel::query()->create([
+            'code' => 'code',
+            'synchronize' => true,
+            'data' => [],
+        ]);
+
+        $productModel->failed();
+
+        $this->assertNotNull($productModel->failed_at);
+        $this->assertEquals(1, $productModel->fail_count);
+        $this->assertTrue($productModel->synchronize);
+
+        $productModel->failed();
+
+        $this->assertNotNull($productModel->failed_at);
+        $this->assertEquals(2, $productModel->fail_count);
+        $this->assertFalse($productModel->synchronize);
+    }
+}
diff --git a/tests/Models/ProductTest.php b/tests/Models/ProductTest.php
index b5b241d..147bef7 100644
--- a/tests/Models/ProductTest.php
+++ b/tests/Models/ProductTest.php
@@ -3,6 +3,7 @@
 namespace JustBetter\AkeneoProducts\Tests\Models;
 
 use JustBetter\AkeneoProducts\Models\Product;
+use JustBetter\AkeneoProducts\Tests\Fakes\Retrievers\Product\ProductRetriever;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
 class ProductTest extends TestCase
@@ -10,7 +11,7 @@ class ProductTest extends TestCase
     /** @test */
     public function it_can_stop_the_synchronization(): void
     {
-        config()->set('akeneo-products.tries', 2);
+        config()->set('akeneo-products.retrievers.product', ProductRetriever::class);
 
         /** @var Product $product */
         $product = Product::query()->create([
diff --git a/tests/Retrievers/BaseRetrieverTest.php b/tests/Retrievers/BaseRetrieverTest.php
deleted file mode 100644
index 4019c1e..0000000
--- a/tests/Retrievers/BaseRetrieverTest.php
+++ /dev/null
@@ -1,18 +0,0 @@
-<?php
-
-namespace JustBetter\AkeneoProducts\Tests\Retrievers;
-
-use JustBetter\AkeneoProducts\Retrievers\BaseRetriever;
-use JustBetter\AkeneoProducts\Retrievers\ProductRetriever;
-use JustBetter\AkeneoProducts\Tests\TestCase;
-
-class BaseRetrieverTest extends TestCase
-{
-    /** @test */
-    public function it_can_get_the_current_retriever(): void
-    {
-        $retriever = BaseRetriever::current();
-
-        $this->assertNotNull($retriever instanceof ProductRetriever);
-    }
-}
diff --git a/tests/Retrievers/Product/BaseProductRetrieverTest.php b/tests/Retrievers/Product/BaseProductRetrieverTest.php
new file mode 100644
index 0000000..a26f77b
--- /dev/null
+++ b/tests/Retrievers/Product/BaseProductRetrieverTest.php
@@ -0,0 +1,18 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Retrievers\Product;
+
+use JustBetter\AkeneoProducts\Retrievers\Product\BaseProductRetriever;
+use JustBetter\AkeneoProducts\Retrievers\Product\ProductRetriever;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class BaseProductRetrieverTest extends TestCase
+{
+    /** @test */
+    public function it_can_get_the_current_retriever(): void
+    {
+        $retriever = BaseProductRetriever::current();
+
+        $this->assertTrue($retriever instanceof ProductRetriever);
+    }
+}
diff --git a/tests/Retrievers/ProductRetrieverTest.php b/tests/Retrievers/Product/ProductRetrieverTest.php
similarity index 78%
rename from tests/Retrievers/ProductRetrieverTest.php
rename to tests/Retrievers/Product/ProductRetrieverTest.php
index dfb2323..d16fef5 100644
--- a/tests/Retrievers/ProductRetrieverTest.php
+++ b/tests/Retrievers/Product/ProductRetrieverTest.php
@@ -1,9 +1,9 @@
 <?php
 
-namespace JustBetter\AkeneoProducts\Tests\Retrievers;
+namespace JustBetter\AkeneoProducts\Tests\Retrievers\Product;
 
 use JustBetter\AkeneoProducts\Exceptions\NotImplementedException;
-use JustBetter\AkeneoProducts\Retrievers\ProductRetriever;
+use JustBetter\AkeneoProducts\Retrievers\Product\ProductRetriever;
 use JustBetter\AkeneoProducts\Tests\TestCase;
 
 class ProductRetrieverTest extends TestCase
diff --git a/tests/Retrievers/ProductModel/BaseProductModelRetrieverTest.php b/tests/Retrievers/ProductModel/BaseProductModelRetrieverTest.php
new file mode 100644
index 0000000..149c606
--- /dev/null
+++ b/tests/Retrievers/ProductModel/BaseProductModelRetrieverTest.php
@@ -0,0 +1,18 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Retrievers\ProductModel;
+
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\BaseProductModelRetriever;
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\ProductModelRetriever;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class BaseProductModelRetrieverTest extends TestCase
+{
+    /** @test */
+    public function it_can_get_the_current_retriever(): void
+    {
+        $retriever = BaseProductModelRetriever::current();
+
+        $this->assertTrue($retriever instanceof ProductModelRetriever);
+    }
+}
diff --git a/tests/Retrievers/ProductModel/ProductModelRetrieverTest.php b/tests/Retrievers/ProductModel/ProductModelRetrieverTest.php
new file mode 100644
index 0000000..02ab056
--- /dev/null
+++ b/tests/Retrievers/ProductModel/ProductModelRetrieverTest.php
@@ -0,0 +1,20 @@
+<?php
+
+namespace JustBetter\AkeneoProducts\Tests\Retrievers\ProductModel;
+
+use JustBetter\AkeneoProducts\Exceptions\NotImplementedException;
+use JustBetter\AkeneoProducts\Retrievers\ProductModel\ProductModelRetriever;
+use JustBetter\AkeneoProducts\Tests\TestCase;
+
+class ProductModelRetrieverTest extends TestCase
+{
+    /** @test */
+    public function it_can_throw_exceptions(): void
+    {
+        $this->expectException(NotImplementedException::class);
+
+        /** @var ProductModelRetriever $retriever */
+        $retriever = app(ProductModelRetriever::class);
+        $retriever->retrieve('code');
+    }
+}