Skip to content

Commit

Permalink
Create README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
makasim authored Jun 12, 2017

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
1 parent 6ff503c commit cea5a50
Showing 1 changed file with 1 addition and 52 deletions.
53 changes: 1 addition & 52 deletions README.md
Original file line number Diff line number Diff line change
@@ -7,60 +7,9 @@ This is where all development happens. The repository provides a friendly enviro

Features:

* [JMS](https://docs.oracle.com/javaee/7/api/javax/jms/package-summary.html) like transport [abstraction](https://github.com/php-enqueue/psr-queue).
* [Feature rich](docs/quick_tour.md).
* [JMS](https://docs.oracle.com/javaee/7/api/javax/jms/package-summary.html) like transport [abstraction](https://github.com/php-enqueue/psr-queue).
* Supports transports [AMQP (RabbitMQ, ActiveMQ)](docs/transport/amqp.md), [STOMP](docs/transport/stomp.md), [Amazon SQS](docs/transport/sqs.md), [Redis](docs/transport/redis.md), [Doctrine DBAL](docs/transport/dbal.md), [Filesystem](docs/transport/filesystem.md), [Null](docs/transport/null.md).
* Generic purpose abstraction level (the transport level).

```php
<?php
use function Enqueue\dsn_to_context;
use function Enqueue\send_queue;
use function Enqueue\consume;
use Enqueue\Psr\PsrMessage;
use Enqueue\Consumption\Result;

// composer require enqueue/enqueue enqueue/amqp-ext

$c = dsn_to_context('amqp:://');

send_queue($c, 'a_queue', 'Hello there');

consume($c, 'a_queue', function(PsrMessage $message) {
$body = $message->getBody();

// to stop consumption: throw new \Enqueue\Consumption\Exception\ConsumptionInterruptedException;

return Result::ACK;
});
```

* Easy to use abstraction level (the client level).

```php
<?php
use Enqueue\SimpleClient\SimpleClient;
use Enqueue\Psr\PsrMessage;
use Enqueue\Consumption\Result;

// composer require enqueue/simple-client enqueue/fs

$client = new SimpleClient('file://');
$client->bind('a_topic', 'a_processor', function(PsrMessage $message) {
$body = $message->getBody();

// to stop consumption: throw new \Enqueue\Consumption\Exception\ConsumptionInterruptedException;

return Result::ACK;
});

$client->setupBroker();

$client->send('a_topic', 'Hello there');

$client->consume();
```

* [Symfony bundle](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/bundle/quick_tour.md)
* [Magento1 extension](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/magento/quick_tour.md)
* [Message bus](http://www.enterpriseintegrationpatterns.com/patterns/messaging/MessageBus.html) support.

0 comments on commit cea5a50

Please sign in to comment.