PHPackages vantukh-kolya/rabbitmq-client - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. [HTTP & Networking](/categories/http) 4. / 5. vantukh-kolya/rabbitmq-client ActiveLibrary[HTTP & Networking](/categories/http) vantukh-kolya/rabbitmq-client ============================= RabbitMQ client 1.13(1y ago)0981MITPHPPHP ^8.0 Since Jan 3Pushed 1y ago1 watchersCompare [ Source](https://github.com/vantukh-kolya/rabbit-mq-client)[ Packagist](https://packagist.org/packages/vantukh-kolya/rabbitmq-client)[ RSS](/packages/vantukh-kolya-rabbitmq-client/feed)WikiDiscussions main Synced 1mo ago READMEChangelog (10)Dependencies (5)Versions (14)Used By (0) Configuration ------------- [](#configuration) Add connection to config/queue.php: ``` 'connections' => [ 'rabbitmq' => [ 'driver' => 'rabbitmq', 'queue' => env('RABBITMQ_QUEUE', 'default'), 'connection' => 'default', 'worker' => env('RABBITMQ_WORKER', 'horizon'), 'hosts' => [ [ 'host' => env('RABBITMQ_HOST', 'rabbitmq'), 'port' => env('RABBITMQ_PORT', 5672), 'user' => env('RABBITMQ_USER', 'guest'), 'password' => env('RABBITMQ_PASSWORD', 'guest'), 'vhost' => env('RABBITMQ_VHOST', '/'), ], ], 'options' => [ 'queue' => [ 'exchange' => env('RABBITMQ_EXCHANGE', 'products_microservice_default_direct'), 'exchange_type' => env('RABBITMQ_EXCHANGE_TYPE', 'direct'), 'exchange_routing_key' => env('RABBITMQ_EXCHANGE_ROUTING_KEY', 'products_microservice.default'), 'job' => \App\RabbitMq\JobHandler::class, ], 'heartbeat' => 10, ] ] ] ``` `'job' => \App\RabbitMq\JobHandler::class` class that response for consuming messages Example of `App\RabbitMq\JobHandler` class ``` use App\RabbitMq\Consumers\ConsumedMessageTypeFactory; use Illuminate\Queue\Jobs\JobName; use VantukhKolya\RabbitMqClient\Queue\Jobs\RabbitMQJob; use Illuminate\Support\Facades\Log; class JobHandler extends RabbitMQJob { public function fire() { $payload = $this->payload(); if (!empty($payload['job'])) { [$class, $method] = JobName::parse($payload['job']); ($this->instance = $this->resolve($class))->{$method}($this, $payload['data']); } else { if (!empty($payload['msgType'])) { $messageType = ConsumedMessageTypeFactory::create($payload['msgType']); if ($messageType) { $this->instance = $messageType; $messageType->handle($this); } else { Log::error('Unknown message type ' . $payload['msgType']); } } } $this->delete(); } protected function failed($e) { $payload = $this->payload(); if (!empty($payload['job'])) { [$class, $method] = JobName::parse($payload['job']); if (method_exists($this->instance = $this->resolve($class), 'failed')) { $this->instance->failed($payload['data'], $e, $payload['uuid'] ?? ''); } } } } ``` Configuration file 'rabbitmq\_system.php' contains information about producers and consumers. Example: ``` use App\RabbitMq\Producers\ProducedMessageTypeCode; use App\RabbitMq\ConsumedMessageTypeCode; use App\RabbitMq\Consumers\ProductQuestionReadByManager; use App\RabbitMq\Consumers\ProductQuestionAnswerReadByManager; return [ 'producers' => [ ProducedMessageTypeCode::Product_viewed->value => [ 'exchange' => [ 'name' => 'products.product.viewed.direct_exchange', 'type' => 'direct', 'routing_key' => 'product.viewed' ], 'horizon_queue' => null ] ], 'consumers' => [ ConsumedMessageTypeCode::Product_question_read_by_manager->value => [ 'handler' => new ProductQuestionReadByManager() ], ConsumedMessageTypeCode::Product_question_answer_read_by_manager->value => [ 'handler' => new ProductQuestionAnswerReadByManager() ], ] ]; ``` App\\RabbitMq\\Producers\\ProducedMessageTypeCode - produced messages codes ``` namespace App\DomainCore\RabbitMq\Producers; enum ProducedMessageTypeCode: string { case Product_viewed = 'product_viewed'; } ``` App\\RabbitMq\\ConsumedMessageTypeCode - consumed messages codes ``` namespace App\DomainCore\RabbitMq; enum ConsumedMessageTypeCode: string { case Product_question_read_by_manager = 'product_question_read_by_manager'; case Product_question_answer_read_by_manager = 'product_question_answer_read_by_manager'; } ``` Usage between different servers ------------------------------- [](#usage-between-different-servers) To consume a message you should create a consumer class that implements `VantukhKolya\RabbitMqClient\Core\MessageTypeInterface` interface. For example: ``` use VantukhKolya\RabbitMqClient\Core\MessageTypeInterface; use VantukhKolya\RabbitMqClient\Queue\Jobs\RabbitMQJob; class ProductViewed implements MessageTypeInterface { public function handle(RabbitMQJob $job): void { $messagePayload = $job->payload(); if (isset($messagePayload['data']['product_code'])) { $product = $this->entityManager->find(Product::class, $messagePayload['data']['product_code']); if ($product) { $product->incrementViewCount(); $this->entityManager->flush(); } } } } ``` Produce message to RabbitMq: ``` use App\DomainCore\RabbitMq\Producers\ProducedMessageTypeCode; use App\DomainCore\RabbitMq\Producers\ProducerInfo; use App\Events\ProductViewed; use VantukhKolya\RabbitMqClient\Core\Message; use VantukhKolya\RabbitMqClient\Core\RabbitMqProducer; $rabbitMqMsq = new Message( ProducedMessageTypeCode::Product_viewed->value, ['product_code' => $event->productCode] ); $producerInfo = ProducerInfo::get(ProducedMessageTypeCode::Product_viewed); RabbitMqProducer::push($rabbitMqMsq, $producerInfo['exchange'], $producerInfo['horizon_queue']) ``` ### Health Score 29 — LowBetter than 60% of packages Maintenance34 Infrequent updates — may be unmaintained Popularity10 Limited adoption so far Community8 Small or concentrated contributor base Maturity54 Maturing project, gaining track record Bus Factor1 Top contributor holds 100% of commits — single point of failure How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~17 days Recently: every ~26 days Total 13 Last Release 649d ago ### Community Maintainers ![](https://www.gravatar.com/avatar/ab60190d925af2956da92362e8d30da96e554901bc743e99b8af723b3b73eb8c?d=identicon)[vantukh-kolya](/maintainers/vantukh-kolya) --- Top Contributors [![vantukh-kolya](https://avatars.githubusercontent.com/u/57218989?v=4)](https://github.com/vantukh-kolya "vantukh-kolya (18 commits)") ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/vantukh-kolya-rabbitmq-client/health.svg) ``` [![Health](https://phpackages.com/badges/vantukh-kolya-rabbitmq-client/health.svg)](https://phpackages.com/packages/vantukh-kolya-rabbitmq-client) ``` ### Alternatives [friendsofsymfony/rest-bundle This Bundle provides various tools to rapidly develop RESTful API's with Symfony 2.8k73.3M319](/packages/friendsofsymfony-rest-bundle)[php-http/discovery Finds and installs PSR-7, PSR-17, PSR-18 and HTTPlug implementations 1.3k309.5M1.2k](/packages/php-http-discovery)[nyholm/psr7 A fast PHP7 implementation of PSR-7 1.3k235.4M2.4k](/packages/nyholm-psr7)[pusher/pusher-php-server Library for interacting with the Pusher REST API 1.5k94.8M293](/packages/pusher-pusher-php-server)[spatie/crawler Crawl all internal links found on a website 2.8k16.3M52](/packages/spatie-crawler)[react/http Event-driven, streaming HTTP client and server implementation for ReactPHP 78126.4M414](/packages/react-http) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)