37 lines
899 B
PHP
37 lines
899 B
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
require __DIR__.'/../vendor/autoload.php';
|
|
|
|
use Amp\ByteStream;
|
|
use Amp\Log\ConsoleFormatter;
|
|
use Amp\Log\StreamHandler;
|
|
use Amp\Loop;
|
|
use Monolog\Logger;
|
|
use Monolog\Processor\PsrLogMessageProcessor;
|
|
use Nsq\Config\ClientConfig;
|
|
use Nsq\Producer;
|
|
|
|
Loop::run(static function () {
|
|
$handler = new StreamHandler(ByteStream\getStdout());
|
|
$handler->setFormatter(new ConsoleFormatter());
|
|
$logger = new Logger('publisher', [$handler], [new PsrLogMessageProcessor()]);
|
|
|
|
$producer = new Producer(
|
|
'tcp://localhost:4150',
|
|
clientConfig: new ClientConfig(
|
|
deflate: false,
|
|
heartbeatInterval: 5000,
|
|
snappy: true,
|
|
),
|
|
logger: $logger,
|
|
);
|
|
|
|
yield $producer->connect();
|
|
|
|
while (true) {
|
|
yield $producer->publish(topic: 'local', body: array_fill(0, 200, 'Message body!'));
|
|
}
|
|
});
|