Skip to content

Commit 3e345fa

Browse files
authored
Create README.md
1 parent 8f2ceaa commit 3e345fa

File tree

1 file changed

+1
-52
lines changed

1 file changed

+1
-52
lines changed

README.md

+1-52
Original file line numberDiff line numberDiff line change
@@ -7,60 +7,9 @@ This is where all development happens. The repository provides a friendly enviro
77

88
Features:
99

10-
* [JMS](https://docs.oracle.com/javaee/7/api/javax/jms/package-summary.html) like transport [abstraction](https://github.com/php-enqueue/psr-queue).
1110
* [Feature rich](docs/quick_tour.md).
11+
* [JMS](https://docs.oracle.com/javaee/7/api/javax/jms/package-summary.html) like transport [abstraction](https://github.com/php-enqueue/psr-queue).
1212
* 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).
13-
* Generic purpose abstraction level (the transport level).
14-
15-
```php
16-
<?php
17-
use function Enqueue\dsn_to_context;
18-
use function Enqueue\send_queue;
19-
use function Enqueue\consume;
20-
use Enqueue\Psr\PsrMessage;
21-
use Enqueue\Consumption\Result;
22-
23-
// composer require enqueue/enqueue enqueue/amqp-ext
24-
25-
$c = dsn_to_context('amqp:://');
26-
27-
send_queue($c, 'a_queue', 'Hello there');
28-
29-
consume($c, 'a_queue', function(PsrMessage $message) {
30-
$body = $message->getBody();
31-
32-
// to stop consumption: throw new \Enqueue\Consumption\Exception\ConsumptionInterruptedException;
33-
34-
return Result::ACK;
35-
});
36-
```
37-
38-
* Easy to use abstraction level (the client level).
39-
40-
```php
41-
<?php
42-
use Enqueue\SimpleClient\SimpleClient;
43-
use Enqueue\Psr\PsrMessage;
44-
use Enqueue\Consumption\Result;
45-
46-
// composer require enqueue/simple-client enqueue/fs
47-
48-
$client = new SimpleClient('file://');
49-
$client->bind('a_topic', 'a_processor', function(PsrMessage $message) {
50-
$body = $message->getBody();
51-
52-
// to stop consumption: throw new \Enqueue\Consumption\Exception\ConsumptionInterruptedException;
53-
54-
return Result::ACK;
55-
});
56-
57-
$client->setupBroker();
58-
59-
$client->send('a_topic', 'Hello there');
60-
61-
$client->consume();
62-
```
63-
6413
* [Symfony bundle](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/bundle/quick_tour.md)
6514
* [Magento1 extension](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/magento/quick_tour.md)
6615
* [Message bus](http://www.enterpriseintegrationpatterns.com/patterns/messaging/MessageBus.html) support.

0 commit comments

Comments
 (0)