Skip to content

Commit 38ae438

Browse files
Add License Headers
1 parent 4d8c62d commit 38ae438

8 files changed

+96
-0
lines changed

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/KafkaMessageStamp.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,24 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
615

716
use RdKafka\Message;
817
use Symfony\Component\Messenger\Stamp\NonSendableStampInterface;
918

19+
/**
20+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
21+
*/
1022
final class KafkaMessageStamp implements NonSendableStampInterface
1123
{
1224
/** @var Message */

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/KafkaReceiver.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
@@ -11,6 +20,9 @@
1120
use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
1221
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
1322

23+
/**
24+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
25+
*/
1426
class KafkaReceiver implements ReceiverInterface
1527
{
1628
/** @var LoggerInterface */

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/KafkaReceiverProperties.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,23 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
615

716
use RdKafka\Conf as KafkaConf;
817

18+
/**
19+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
20+
*/
921
final class KafkaReceiverProperties
1022
{
1123
/** @var KafkaConf */

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/KafkaSender.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
@@ -11,6 +20,9 @@
1120
use Symfony\Component\Messenger\Transport\Sender\SenderInterface;
1221
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
1322

23+
/**
24+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
25+
*/
1426
class KafkaSender implements SenderInterface
1527
{
1628
/** @var LoggerInterface */

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/KafkaSenderProperties.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,23 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
615

716
use RdKafka\Conf as KafkaConf;
817

18+
/**
19+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
20+
*/
921
final class KafkaSenderProperties
1022
{
1123
/** @var KafkaConf */

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/KafkaTransport.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
@@ -9,6 +18,9 @@
918
use Symfony\Component\Messenger\Transport\Serialization\SerializerInterface;
1019
use Symfony\Component\Messenger\Transport\TransportInterface;
1120

21+
/**
22+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
23+
*/
1224
class KafkaTransport implements TransportInterface
1325
{
1426
/** @var LoggerInterface */

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/KafkaTransportFactory.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
@@ -19,6 +28,9 @@
1928
use Symfony\Component\Messenger\Transport\TransportFactoryInterface;
2029
use Symfony\Component\Messenger\Transport\TransportInterface;
2130

31+
/**
32+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
33+
*/
2234
class KafkaTransportFactory implements TransportFactoryInterface
2335
{
2436
private const DSN_PROTOCOLS = [

src/Symfony/Component/Messenger/Bridge/Kafka/Transport/RdKafkaFactory.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
<?php
22

3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
312
declare(strict_types=1);
413

514
namespace Symfony\Component\Messenger\Bridge\Kafka\Transport;
@@ -8,6 +17,9 @@
817
use RdKafka\KafkaConsumer;
918
use RdKafka\Producer as KafkaProducer;
1019

20+
/**
21+
* @author Konstantin Scheumann <konstantin@konstantin.codes>
22+
*/
1123
class RdKafkaFactory
1224
{
1325
public function createConsumer(Conf $conf): KafkaConsumer

0 commit comments

Comments
 (0)