Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

ingresse/message-queue-php

Folders and files

NameName
Last commit message
Last commit date

Latest commit

History

39 Commits

Repository files navigation

##Message Queue php library to publish and subscribe to queues with diferent types of adapters.

##Current supported adapters:

##Installation

With Composer Add ingresse/message-queue-php as dependency in composer.json

 "require": {
 ...
 "ingresse/message-queue-php" : "1.*"
 ...
 }

Run composer update.

Now the message-queue-php will be autoloaded into your project.

 require 'vendor/autoload.php';
 $configData = [
 'connection' => [
 'host' => 'localhost',
 'port' => 5672,
 'user' => 'guest',
 'pass' => 'guest',
 'vhost' => '/'
 ],
 'queues' => [
 'worker.test' => [
 'passive' => false,
 'durable' => true,
 'exclusive' => false,
 'autoDelete' => false,
 'delivery_mode' => 2
 ]
 ],
 'exchanges' => [
 'exchange.test' => [ 
 'type' => 'fanout'
 'passive' => false,
 'durable' => true,
 'auto_delete' => false,
 'internal' => false,
 'nowait' => false,
 'arguments' => false,
 'ticket' => false,
 'delivery_mode' => 2
 ]
 ],
 'consume' => [
 'Simpler' => [
 'noLocal' => false,
 'noAck' => false,
 'exclusive' => false,
 'noWait' => false
 ]
 ],
 'logger' => [
 'host' => 'localhost',
 'port' => 6379,
 'key' => 'logstash',
 'channel' => 'message-queue-php'
 path' => '/var/log/message-queue-php.log'
 ]
 ];
 $config = new MessageQueuePHP\Config\AMQPConfig($configData);
 $amqpAdapter = new MessageQueuePHP\Adapter\AMQPAdapter($config);
 $myPublisher = new MessageQueuePHP\Publisher\Publisher($amqpAdapter, 'worker.test');
 $myPublisher
 ->setMessage($myData)
 ->send();
 $subscriber = new MessageQueuePHP\Subscriber\Subscriber($amqpAdapter);
 $simplerConsumer = new MessageQueuePHP\Subscriber\Consumer\SimplerConsumer;
 $subscriber
 ->setConsumer($simplerConsumer)
 ->subscribe('worker.test')
 ->consume();

About

PHP Message Queue

Topics

Resources

Stars

Watchers

Forks

Packages

No packages published

Contributors 5

Languages

AltStyle によって変換されたページ (->オリジナル) /