diff --git a/phpunit.xml b/phpunit.xml
index 82ce746..1fba752 100644
--- a/phpunit.xml
+++ b/phpunit.xml
@@ -19,6 +19,9 @@
         <testsuite name="unit">
             <directory>tests/Unit</directory>
         </testsuite>
+        <testsuite name="integration">
+            <directory>tests/Integration</directory>
+        </testsuite>
     </testsuites>
 
     <php>
diff --git a/src/Attribute/Message.php b/src/Attribute/Message.php
index 73f8d98..793ceb6 100644
--- a/src/Attribute/Message.php
+++ b/src/Attribute/Message.php
@@ -17,6 +17,7 @@ public function __construct(
         public readonly string $name,
         public array $properties = [],
         public array $channels = [],
+        public array $operations = [],
     ) {
     }
 
@@ -26,6 +27,7 @@ public function toArray(): array
             'name' => $this->name,
             'properties' => array_map(static fn(PropertyInterface $property) => $property->toArray(), $this->properties),
             'channels' => array_map(static fn(Channel $channel) => $channel->toArray(), $this->channels),
+            'operations' => array_map(static fn(Operation $operation) => $operation->toArray(), $this->operations),
         ];
     }
 
@@ -39,6 +41,11 @@ public function addChannel(Channel $channel): void
         $this->channels[] = $channel;
     }
 
+    public function addOperation(Operation $operation): void
+    {
+        $this->operations[] = $operation;
+    }
+
     public function enrich(self $self): self
     {
         // UPDATE EXISTING
diff --git a/src/Attribute/Operation.php b/src/Attribute/Operation.php
new file mode 100644
index 0000000..f52fcdb
--- /dev/null
+++ b/src/Attribute/Operation.php
@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Ferror\AsyncapiDocBundle\Attribute;
+
+use Attribute;
+use Ferror\AsyncapiDocBundle\Schema\V3\OperationType;
+
+#[Attribute(Attribute::TARGET_CLASS)]
+class Operation
+{
+    public function __construct(
+        public string $name,
+        public OperationType $type = OperationType::SEND,
+        public array $channels = [],
+    ) {
+    }
+
+    public function toArray(): array
+    {
+        return [
+            'name' => $this->name,
+            'type' => $this->type->value,
+            'channels' => array_map(
+                static fn (Channel $channel) => $channel->toArray(),
+                $this->channels
+            ),
+        ];
+    }
+
+    public function addChannel(Channel $channel): void
+    {
+        $this->channels[] = $channel;
+    }
+}
diff --git a/src/DocumentationStrategy/AttributeDocumentationStrategy.php b/src/DocumentationStrategy/AttributeDocumentationStrategy.php
index d3fe12b..9978569 100644
--- a/src/DocumentationStrategy/AttributeDocumentationStrategy.php
+++ b/src/DocumentationStrategy/AttributeDocumentationStrategy.php
@@ -6,6 +6,7 @@
 
 use Ferror\AsyncapiDocBundle\Attribute\Channel;
 use Ferror\AsyncapiDocBundle\Attribute\Message;
+use Ferror\AsyncapiDocBundle\Attribute\Operation;
 use ReflectionAttribute;
 use ReflectionClass;
 use ReflectionException;
@@ -50,6 +51,14 @@ public function document(string $class): Message
             $message->addChannel($channelAttribute->newInstance());
         }
 
+        // Channels are optional as it's possible to document just Messages.
+        /** @var ReflectionAttribute<Operation>[] $operationAttributes */
+        $operationAttributes = $reflection->getAttributes(Operation::class);
+
+        foreach ($operationAttributes as $operationAttribute) {
+            $message->addOperation($operationAttribute->newInstance());
+        }
+
         return $message;
     }
 }
diff --git a/src/Schema/V3/OperationRenderer.php b/src/Schema/V3/OperationRenderer.php
new file mode 100644
index 0000000..ac86384
--- /dev/null
+++ b/src/Schema/V3/OperationRenderer.php
@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Ferror\AsyncapiDocBundle\Schema\V3;
+
+final readonly class OperationRenderer
+{
+    public function render(array $document): array
+    {
+        $operations = [];
+
+        foreach ($document['operations'] as $operation) {
+            foreach ($operation['channels'] as $channel) {
+                $operations[$operation['name']] = [
+                    'action' => $operation['type'],
+                    'channel' => [
+                         '$ref' => '#/channels/' . $channel['name'],
+                    ],
+                ];
+            }
+        }
+
+        return $operations;
+    }
+}
diff --git a/src/Schema/V3/OperationType.php b/src/Schema/V3/OperationType.php
new file mode 100644
index 0000000..2f6e302
--- /dev/null
+++ b/src/Schema/V3/OperationType.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Ferror\AsyncapiDocBundle\Schema\V3;
+
+enum OperationType: string
+{
+    case SEND = 'send';
+    case RECEIVE = 'receive';
+}
+
diff --git a/tests/Integration/DumpSpecificationConsoleTest.php b/tests/Integration/DumpSpecificationConsoleTest.php
index aabda68..14f1f9d 100644
--- a/tests/Integration/DumpSpecificationConsoleTest.php
+++ b/tests/Integration/DumpSpecificationConsoleTest.php
@@ -62,8 +62,12 @@ public function testExecuteClass(): void
         $this->assertEquals($expectedDisplay, $display);
     }
 
-    public function testExecuteYaml(): void
+    public function testExecuteYamlV2(): void
     {
+        if ($this->isV3()) {
+            $this->markTestSkipped('Skipping schema V2 test on V3 variable');
+        }
+
         $kernel = self::bootKernel();
         $application = new Application($kernel);
 
@@ -195,6 +199,141 @@ public function testExecuteYaml(): void
         }
     }
 
+    public function testExecuteYamlV3(): void
+    {
+        if (false === $this->isV3()) {
+            $this->markTestSkipped('Skipping schema V3 test on V2 variable');
+        }
+
+        $kernel = self::bootKernel();
+        $application = new Application($kernel);
+
+        $command = $application->find('ferror:asyncapi:dump');
+        $commandTester = new CommandTester($command);
+        $commandTester->execute(['format' => 'yaml']);
+
+        $commandTester->assertCommandIsSuccessful();
+
+        $display = $commandTester->getDisplay();
+
+        $expectedDisplay = <<<YAML
+asyncapi: 3.0.0
+info:
+  title: 'Service Example API'
+  version: 1.2.3
+  description: 'This service is in charge of processing user signups'
+channels:
+  user_signed_up:
+    messages:
+      UserSignedUp:
+        \$ref: '#/components/messages/UserSignedUp'
+  payment_executed:
+    messages:
+      PaymentExecuted:
+        \$ref: '#/components/messages/PaymentExecuted'
+  product.created:
+    messages:
+      ProductCreated:
+        \$ref: '#/components/messages/ProductCreated'
+components:
+  messages:
+    UserSignedUp:
+      payload:
+        type: object
+        properties:
+          name:
+            type: string
+            description: 'Name of the user'
+            format: string
+            example: John
+          email:
+            type: string
+            description: 'Email of the user'
+            format: email
+            example: john@example.com
+          age:
+            type: integer
+            description: 'Age of the user'
+            format: int32
+            example: '18'
+          isCitizen:
+            type: boolean
+            description: 'Is user a citizen'
+            format: boolean
+            example: 'true'
+        required:
+          - name
+          - email
+          - age
+          - isCitizen
+    PaymentExecuted:
+      payload:
+        type: object
+        properties:
+          amount:
+            type: number
+          createdAt:
+            type: string
+        required:
+          - amount
+          - createdAt
+    ProductCreated:
+      payload:
+        type: object
+        properties:
+          id:
+            type: integer
+          amount:
+            type: number
+          currency:
+            type: string
+          isPaid:
+            type: boolean
+          createdAt:
+            type: string
+            format: date-time
+          week:
+            type: integer
+          payment:
+            type: string
+          products:
+            type: string
+          tags:
+            type: string
+        required:
+          - id
+          - amount
+          - currency
+          - isPaid
+          - createdAt
+          - week
+          - payment
+          - products
+          - tags
+servers:
+  production:
+    protocol: amqp
+    description: 'This is production broker.'
+    host: broker.mycompany.com
+  staging:
+    protocol: amqp
+    description: 'This is staging broker.'
+    host: broker.mycompany.com
+
+
+YAML;
+
+        $this->assertEquals($expectedDisplay, $display);
+
+        mkdir(dirname(__DIR__) . '/../var/' . $this->getSchemaVersion());
+
+        $content = file_put_contents(dirname(__DIR__) . '/../var/' . $this->getSchemaVersion() . '/asyncapi.yaml', $display);
+
+        if (false === $content) {
+            throw new RuntimeException('Schema file was not save');
+        }
+    }
+
     public function testExecuteJson(): void
     {
         $kernel = self::bootKernel();
diff --git a/tests/Unit/DocumentationEditorTest.php b/tests/Unit/DocumentationEditorTest.php
index b75b995..c08dfac 100644
--- a/tests/Unit/DocumentationEditorTest.php
+++ b/tests/Unit/DocumentationEditorTest.php
@@ -43,6 +43,7 @@ public function testDocument(): void
                 ],
             ],
             'channels' => [],
+            'operations' => [],
         ];
 
         $this->assertEquals($expected, $actual);
diff --git a/tests/Unit/DocumentationStrategy/AttributeDocumentationStrategyTest.php b/tests/Unit/DocumentationStrategy/AttributeDocumentationStrategyTest.php
index 3f723da..6e00d7c 100644
--- a/tests/Unit/DocumentationStrategy/AttributeDocumentationStrategyTest.php
+++ b/tests/Unit/DocumentationStrategy/AttributeDocumentationStrategyTest.php
@@ -60,6 +60,7 @@ public function testUserSignedUp(): void
                     'type' => 'subscribe',
                 ],
             ],
+            'operations' => [],
         ];
 
         $this->assertEquals($expected, $actual);
@@ -154,6 +155,7 @@ public function testProductCreated(): void
                     'type' => 'subscribe',
                 ],
             ],
+            'operations' => [],
         ];
 
         $this->assertEquals($expected, $actual);
diff --git a/tests/Unit/DocumentationStrategy/ReflectionDocumentationStrategyTest.php b/tests/Unit/DocumentationStrategy/ReflectionDocumentationStrategyTest.php
index daf47b6..5c18bc2 100644
--- a/tests/Unit/DocumentationStrategy/ReflectionDocumentationStrategyTest.php
+++ b/tests/Unit/DocumentationStrategy/ReflectionDocumentationStrategyTest.php
@@ -52,6 +52,7 @@ public function test(): void
                 ],
             ],
             'channels' => [],
+            'operations' => [],
         ];
 
         $this->assertEquals($expected, $documentation->document(UserSignedUp::class)->toArray());
@@ -98,9 +99,9 @@ public function testEnum(): void
                 ],
             ],
             'channels' => [],
+            'operations' => [],
         ];
 
-
         $actual = $documentation->document(ProductCreated::class)->toArray();
 
         $this->assertEquals($expected, $actual);
diff --git a/tests/Unit/Schema/V3/OperationRendererTest.php b/tests/Unit/Schema/V3/OperationRendererTest.php
new file mode 100644
index 0000000..ddc835f
--- /dev/null
+++ b/tests/Unit/Schema/V3/OperationRendererTest.php
@@ -0,0 +1,82 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Ferror\AsyncapiDocBundle\Tests\Unit\Schema\V3;
+
+use Ferror\AsyncapiDocBundle\Schema\V3\ChannelRenderer;
+use Ferror\AsyncapiDocBundle\Schema\V3\OperationRenderer;
+use PHPUnit\Framework\TestCase;
+
+final class OperationRendererTest extends TestCase
+{
+    public function testItRendersSendAction(): void
+    {
+        $renderer = new OperationRenderer();
+
+        $document = [
+            'name' => 'UserSignedUp',
+            'properties' => [],
+            'operations' => [
+                [
+                    'name' => 'UserSignedUpOperation',
+                    'type' => 'send',
+                    'channels' => [
+                        [
+                            'name' => 'UserSignedUpChannel',
+                            'type' => 'subscribe',
+                        ]
+                    ],
+                ]
+            ],
+        ];
+
+        $actual = $renderer->render($document);
+
+        $expected = [
+            'UserSignedUpOperation' => [
+                'action' => 'send',
+                'channel' => [
+                    '$ref' => '#/channels/UserSignedUpChannel',
+                ]
+            ]
+        ];
+
+        $this->assertEquals($expected, $actual);
+    }
+
+    public function testItRendersReceiveAction(): void
+    {
+        $renderer = new OperationRenderer();
+
+        $document = [
+            'name' => 'UserSignedUp',
+            'properties' => [],
+            'operations' => [
+                [
+                    'name' => 'UserSignedUpOperation',
+                    'type' => 'receive',
+                    'channels' => [
+                        [
+                            'name' => 'UserSignedUpChannel',
+                            'type' => 'subscribe',
+                        ]
+                    ],
+                ]
+            ],
+        ];
+
+        $actual = $renderer->render($document);
+
+        $expected = [
+            'UserSignedUpOperation' => [
+                'action' => 'receive',
+                'channel' => [
+                    '$ref' => '#/channels/UserSignedUpChannel',
+                ]
+            ]
+        ];
+
+        $this->assertEquals($expected, $actual);
+    }
+}