diff --git a/.gitignore b/.gitignore
index c719a34..0887d25 100644
--- a/.gitignore
+++ b/.gitignore
@@ -6,3 +6,4 @@
 /.phpunit.cache
 /clover.xml
 /coveralls-upload.json
+/tests/Integration/TestApplication/var/
diff --git a/.php-cs-fixer.php b/.php-cs-fixer.php
index 78082c3..64c2119 100644
--- a/.php-cs-fixer.php
+++ b/.php-cs-fixer.php
@@ -3,6 +3,7 @@
 $finder = PhpCsFixer\Finder::create()
     ->in(__DIR__.'/src')
     ->in(__DIR__.'/tests')
+    ->exclude('Integration/TestApplication/var')
 ;
 
 $config = new PhpCsFixer\Config();
diff --git a/composer.json b/composer.json
index 9731f8e..7eed89b 100644
--- a/composer.json
+++ b/composer.json
@@ -10,7 +10,9 @@
         "symfony/messenger": "^5.4|^6.4|^7.0"
     },
     "require-dev": {
-        "phpunit/phpunit": "^10.1"
+        "phpunit/phpunit": "^10.1",
+        "symfony/framework-bundle": "^5.4|^6.4|7.0",
+        "symfony/test-pack": "^1.0"
     },
     "license": "MIT",
     "autoload": {
@@ -20,6 +22,7 @@
     },
     "autoload-dev": {
         "psr-4": {
+            "Tienvx\\Bundle\\PactMessengerBundle\\Tests\\Integration\\TestApplication\\": "tests/Integration/TestApplication/src/",
             "Tienvx\\Bundle\\PactMessengerBundle\\Tests\\": "tests/"
         }
     },
diff --git a/phpstan.neon b/phpstan.neon
index 47e3df0..684ce9c 100644
--- a/phpstan.neon
+++ b/phpstan.neon
@@ -3,3 +3,5 @@ parameters:
     paths:
         - src
         - tests
+    excludePaths:
+        - 'tests/Integration/TestApplication/var'
diff --git a/phpunit.xml.dist b/phpunit.xml.dist
index 764d561..e5509b6 100644
--- a/phpunit.xml.dist
+++ b/phpunit.xml.dist
@@ -1,6 +1,12 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!-- https://phpunit.readthedocs.io/en/latest/configuration.html -->
 <phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="https://schema.phpunit.de/10.1/phpunit.xsd" backupGlobals="false" colors="true" bootstrap="vendor/autoload.php" cacheDirectory=".phpunit.cache">
+  <php>
+    <ini name="display_errors" value="1"/>
+    <ini name="error_reporting" value="-1"/>
+    <server name="SHELL_VERBOSITY" value="-1"/>
+    <server name="KERNEL_CLASS" value="Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Kernel"/>
+  </php>
   <testsuites>
     <testsuite name="tests">
       <directory>tests</directory>
diff --git a/tests/Integration/Service/EnvelopeCollectorTest.php b/tests/Integration/Service/EnvelopeCollectorTest.php
new file mode 100644
index 0000000..bc2d2cf
--- /dev/null
+++ b/tests/Integration/Service/EnvelopeCollectorTest.php
@@ -0,0 +1,44 @@
+<?php
+
+namespace Tienvx\Bundle\MbtBundle\Tests\Integration\Service;
+
+use Symfony\Bundle\FrameworkBundle\Test\KernelTestCase;
+use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\MessageBusInterface;
+use Tienvx\Bundle\PactMessengerBundle\Service\EnvelopeCollectorInterface;
+use Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message\UserCreated;
+use Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message\UserDeleted;
+use Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message\UserUpdated;
+
+class EnvelopeCollectorTest extends KernelTestCase
+{
+    private int $id = 123;
+
+    public function testEnvelopCollector(): void
+    {
+        self::bootKernel();
+
+        $container = static::getContainer();
+
+        $bus = $container->get(MessageBusInterface::class);
+        $bus->dispatch(new UserCreated($this->id));
+        $bus->dispatch(new UserUpdated($this->id));
+        $bus->dispatch(new UserDeleted($this->id));
+
+        $collector = $container->get(EnvelopeCollectorInterface::class);
+        $this->assertCount(3, $all = $collector->getAll());
+
+        $this->assertInstanceOf(Envelope::class, $created = $collector->getSingle(UserCreated::class));
+        $this->assertTrue(in_array($created, $all));
+        $this->assertInstanceOf(UserCreated::class, $message = $created->getMessage());
+        $this->assertSame($this->id, $message->userId);
+        $this->assertInstanceOf(Envelope::class, $updated = $collector->getSingle(UserUpdated::class));
+        $this->assertTrue(in_array($updated, $all));
+        $this->assertInstanceOf(UserUpdated::class, $message = $updated->getMessage());
+        $this->assertSame($this->id, $message->userId);
+        $this->assertInstanceOf(Envelope::class, $deleted = $collector->getSingle(UserDeleted::class));
+        $this->assertTrue(in_array($deleted, $all));
+        $this->assertInstanceOf(UserDeleted::class, $message = $deleted->getMessage());
+        $this->assertSame($this->id, $message->userId);
+    }
+}
diff --git a/tests/Integration/TestApplication/config/packages/framework.php b/tests/Integration/TestApplication/config/packages/framework.php
new file mode 100644
index 0000000..e217637
--- /dev/null
+++ b/tests/Integration/TestApplication/config/packages/framework.php
@@ -0,0 +1,29 @@
+<?php
+
+use Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Kernel;
+
+$configuration = [
+    'http_method_override' => false,
+    'handle_all_throwables' => true,
+    'php_errors' => [
+        'log' => true,
+    ],
+    'test' => true,
+    'messenger' => [
+        'transports' => [
+            'async' => 'in-memory://',
+            'audit' => 'in-memory://',
+        ],
+        'routing' => [
+            'Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message\UserCreated' => 'async',
+            'Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message\UserUpdated' => 'async',
+            'Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message\UserDeleted' => ['async', 'audit'],
+        ],
+    ],
+];
+
+if (Kernel::MAJOR_VERSION <= 5) {
+    unset($configuration['handle_all_throwables']);
+}
+
+$container->loadFromExtension('framework', $configuration);
diff --git a/tests/Integration/TestApplication/config/services.php b/tests/Integration/TestApplication/config/services.php
new file mode 100644
index 0000000..dcd08c6
--- /dev/null
+++ b/tests/Integration/TestApplication/config/services.php
@@ -0,0 +1,14 @@
+<?php
+
+namespace Symfony\Component\DependencyInjection\Loader\Configurator;
+
+return static function (ContainerConfigurator $container) {
+    $services = $container->services()
+        ->defaults()
+            ->autowire()
+            ->autoconfigure()
+    ;
+
+    $services->load('Tienvx\\Bundle\\PactMessengerBundle\\Tests\\Integration\\TestApplication\\', '../src/*')
+        ->exclude('../{Entity,Tests,Kernel.php}');
+};
diff --git a/tests/Integration/TestApplication/src/Kernel.php b/tests/Integration/TestApplication/src/Kernel.php
new file mode 100644
index 0000000..8703948
--- /dev/null
+++ b/tests/Integration/TestApplication/src/Kernel.php
@@ -0,0 +1,41 @@
+<?php
+
+namespace Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication;
+
+use Symfony\Bundle\FrameworkBundle\FrameworkBundle;
+use Symfony\Bundle\FrameworkBundle\Kernel\MicroKernelTrait;
+use Symfony\Component\Config\Loader\LoaderInterface;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\HttpKernel\Kernel as SymfonyKernel;
+use Tienvx\Bundle\PactMessengerBundle\TienvxPactMessengerBundle;
+
+final class Kernel extends SymfonyKernel
+{
+    use MicroKernelTrait;
+
+    public function __construct()
+    {
+        parent::__construct('test', true);
+    }
+
+    public function registerBundles(): iterable
+    {
+        return [
+            new FrameworkBundle(),
+            new TienvxPactMessengerBundle(),
+        ];
+    }
+
+    public function getProjectDir(): string
+    {
+        return \dirname(__DIR__);
+    }
+
+    protected function configureContainer(ContainerBuilder $containerBuilder, LoaderInterface $loader): void
+    {
+        $loader->load($this->getProjectDir().'/config/{packages}/*.php', 'glob');
+        $loader->load($this->getProjectDir().'/config/{packages}/'.$this->environment.'/*.php', 'glob');
+        $loader->load($this->getProjectDir().'/config/{services}.php', 'glob');
+        $loader->load($this->getProjectDir().'/config/{services}_'.$this->environment.'.php', 'glob');
+    }
+}
diff --git a/tests/Integration/TestApplication/src/Message/UserCreated.php b/tests/Integration/TestApplication/src/Message/UserCreated.php
new file mode 100644
index 0000000..8693d3c
--- /dev/null
+++ b/tests/Integration/TestApplication/src/Message/UserCreated.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message;
+
+class UserCreated
+{
+    public function __construct(public readonly int $userId)
+    {
+    }
+}
diff --git a/tests/Integration/TestApplication/src/Message/UserDeleted.php b/tests/Integration/TestApplication/src/Message/UserDeleted.php
new file mode 100644
index 0000000..a188f37
--- /dev/null
+++ b/tests/Integration/TestApplication/src/Message/UserDeleted.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message;
+
+class UserDeleted
+{
+    public function __construct(public readonly int $userId)
+    {
+    }
+}
diff --git a/tests/Integration/TestApplication/src/Message/UserUpdated.php b/tests/Integration/TestApplication/src/Message/UserUpdated.php
new file mode 100644
index 0000000..b52d61c
--- /dev/null
+++ b/tests/Integration/TestApplication/src/Message/UserUpdated.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace Tienvx\Bundle\PactMessengerBundle\Tests\Integration\TestApplication\Message;
+
+class UserUpdated
+{
+    public function __construct(public readonly int $userId)
+    {
+    }
+}
diff --git a/tests/DependencyInjection/TienvxPactMessengerExtensionTest.php b/tests/Unit/DependencyInjection/TienvxPactMessengerExtensionTest.php
similarity index 96%
rename from tests/DependencyInjection/TienvxPactMessengerExtensionTest.php
rename to tests/Unit/DependencyInjection/TienvxPactMessengerExtensionTest.php
index e592f0f..00eec93 100644
--- a/tests/DependencyInjection/TienvxPactMessengerExtensionTest.php
+++ b/tests/Unit/DependencyInjection/TienvxPactMessengerExtensionTest.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace Tienvx\Bundle\MbtBundle\Tests\DependencyInjection;
+namespace Tienvx\Bundle\MbtBundle\Tests\Unit\DependencyInjection;
 
 use PHPUnit\Framework\TestCase;
 use Symfony\Component\DependencyInjection\ContainerBuilder;