Skip to content

Commit a6d2b33

Browse files
balabisbalabis
committed
2 parents 0fbfc4d + 61177d7 commit a6d2b33

File tree

27 files changed

+86
-30
lines changed

27 files changed

+86
-30
lines changed

‎docs/client/supported_brokers.md‎

Lines changed: 35 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -6,38 +6,46 @@ nav_order: 3
66
---
77
{% include support.md %}
88

9-
# Client. Supported brokers
9+
# Client Supported brokers
1010

1111
Here's the list of transports supported by Enqueue Client:
1212

13-
| Transport | Package | DSN |
14-
|:-------------------:|:----------------------------------------------------------:|:-------------------------------:|
15-
| AMQP, RabbitMQ | [enqueue/amqp-bunny](../transport/amqp_bunny.md) | amqp: amqp+bunny: |
16-
| AMQP, RabbitMQ | [enqueue/amqp-lib](../transport/amqp_lib.md) | amqp: amqp+lib: amqp+rabbitmq: |
17-
| AMQP, RabbitMQ | [enqueue/amqp-ext](../transport/amqp.md) | amqp: amqp+ext: |
18-
| Doctrine DBAL | [enqueue/dbal](../transport/dbal.md) | mysql: pgsql: pdo_pgsql etc |
19-
| Filesystem | [enqueue/fs](../transport/fs.md) | file:///foo/bar |
20-
| Google PubSub | [enqueue/gps](../transport/gps.md) | gps: |
21-
| Redis | [enqueue/redis](../transport/redis.md) | redis: |
22-
| Amazon SQS | [enqueue/sqs](../transport/sqs.md) | sqs: |
23-
| STOMP, RabbitMQ | [enqueue/stomp](../transport/stomp.md) | stomp: |
24-
| Kafka | [enqueue/rdkafka](../transport/kafka.md) | kafka: |
25-
| Null | [enqueue/null](../transport/null.md) | null: |
13+
| Transport | Package | DSN |
14+
|:---------------------:|:----------------------------------------------------------:|:-------------------------------:|
15+
| AMQP, RabbitMQ | [enqueue/amqp-ext](../transport/amqp.md) | amqp: amqp+ext: |
16+
| AMQP, RabbitMQ | [enqueue/amqp-bunny](../transport/amqp_bunny.md) | amqp: amqp+bunny: |
17+
| AMQP, RabbitMQ | [enqueue/amqp-lib](../transport/amqp_lib.md) | amqp: amqp+lib: amqp+rabbitmq: |
18+
| Doctrine DBAL | [enqueue/dbal](../transport/dbal.md) | mysql: pgsql: pdo_pgsql etc |
19+
| Filesystem | [enqueue/fs](../transport/fs.md) | file:///foo/bar |
20+
| Gearman | [enqueue/gearman](../transport/gearman.md) | gearman: |
21+
| GPS, Google PubSub | [enqueue/gps](../transport/gps.md) | gps: |
22+
| Kafka | [enqueue/rdkafka](../transport/kafka.md) | kafka: |
23+
| MongoDB | [enqueue/mongodb](../transport/mongodb.md) | mongodb: |
24+
| Null | [enqueue/null](../transport/null.md) | null: |
25+
| Pheanstalk, Beanstalk | [enqueue/pheanstalk](../transport/pheanstalk.md) | beanstalk: |
26+
| Redis | [enqueue/redis](../transport/redis.md) | redis: |
27+
| Amazon SQS | [enqueue/sqs](../transport/sqs.md) | sqs: |
28+
| STOMP, RabbitMQ | [enqueue/stomp](../transport/stomp.md) | stomp: |
29+
| WAMP | [enqueue/wamp](../transport/wamp.md) | wamp: |
2630

27-
Here's the list of protocols and Client features supported by them
31+
## Transport Features
2832

29-
| Protocol | Priority | Delay | Expiration | Setup broker | Message bus |
30-
|:--------------:|:--------:|:--------:|:----------:|:------------:|:-----------:|
31-
| AMQP | No | No | Yes | Yes | Yes |
32-
| RabbitMQ AMQP | Yes | Yes | Yes | Yes | Yes |
33-
| STOMP | No | No | Yes | No | Yes** |
34-
| RabbitMQ STOMP | Yes | Yes | Yes | Yes*** | Yes** |
35-
| Filesystem | No | No | No | Yes | No |
36-
| Redis | No | No | No | Not needed | No |
37-
| Doctrine DBAL | Yes | Yes | No | Yes | No |
38-
| Amazon SQS | No | Yes | No | Yes | Not impl |
39-
| Kafka | No | No | No | Yes | No |
40-
| Google PubSub | Not impl | Not impl | Not impl | Yes | Not impl |
33+
| Protocol | Priority | Delay | Expiration | Setup broker | Message bus | Heartbeat |
34+
|:--------------:|:--------:|:--------:|:----------:|:------------:|:-----------:|:---------:|
35+
| AMQP | No | No | Yes | Yes | Yes | No |
36+
| RabbitMQ AMQP | Yes | Yes | Yes | Yes | Yes | Yes |
37+
| Doctrine DBAL | Yes | Yes | No | Yes | No | No |
38+
| Filesystem | No | No | Yes | Yes | No | No |
39+
| Gearman | No | No | No | No | No | No |
40+
| Google PubSub | Not impl | Not impl | Not impl | Yes | Not impl | No |
41+
| Kafka | No | No | No | Yes | No | No |
42+
| MongoDB | Yes | Yes | Yes | Yes | No | No |
43+
| Pheanstalk | Yes | Yes | Yes | No | No | No |
44+
| Redis | No | Yes | Yes | Not needed | No | No |
45+
| Amazon SQS | No | Yes | No | Yes | Not impl | No |
46+
| STOMP | No | No | Yes | No | Yes** | No |
47+
| RabbitMQ STOMP | Yes | Yes | Yes | Yes*** | Yes** | Yes |
48+
| WAMP | No | No | No | No | No | No |
4149

4250
* \*\* Possible if topics (exchanges) are configured on broker side manually.
4351
* \*\*\* Possible if RabbitMQ Management Plugin is installed.

‎docs/transport/index.md‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,3 +7,5 @@ permalink: /transport
77
---
88

99
{:toc}
10+
11+
[Feature Comparison Table](../client/supported_brokers.md#transport-features)

‎pkg/amqp-bunny/.travis.yml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ language: php
88
php:
99
- '7.1'
1010
- '7.2'
11+
- '7.3'
12+
- '7.4'
1113

1214
cache:
1315
directories:

‎pkg/amqp-ext/.travis.yml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ language: php
88
php:
99
- '7.1'
1010
- '7.2'
11+
- '7.3'
12+
- '7.4'
1113

1214
cache:
1315
directories:

‎pkg/amqp-lib/.travis.yml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ language: php
88
php:
99
- '7.1'
1010
- '7.2'
11+
- '7.3'
12+
- '7.4'
1113

1214
cache:
1315
directories:

‎pkg/amqp-lib/AmqpContext.php‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ public function bind(InteropAmqpBind $bind): void
220220
$bind->getTarget()->getTopicName(),
221221
$bind->getRoutingKey(),
222222
(bool) ($bind->getFlags() & InteropAmqpBind::FLAG_NOWAIT),
223-
$bind->getArguments()
223+
new AMQPTable($bind->getArguments())
224224
);
225225
// bind exchange to queue
226226
} else {
@@ -229,7 +229,7 @@ public function bind(InteropAmqpBind $bind): void
229229
$bind->getSource()->getTopicName(),
230230
$bind->getRoutingKey(),
231231
(bool) ($bind->getFlags() & InteropAmqpBind::FLAG_NOWAIT),
232-
$bind->getArguments()
232+
new AMQPTable($bind->getArguments())
233233
);
234234
}
235235
}

‎pkg/async-command/.travis.yml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ language: php
88
php:
99
- '7.1'
1010
- '7.2'
11+
- '7.3'
12+
- '7.4'
1113

1214
cache:
1315
directories:

‎pkg/async-command/DependencyInjection/AsyncCommandExtension.php‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,8 @@ public function load(array $configs, ContainerBuilder $container)
2424

2525
$id = sprintf('enqueue.async_command.%s.run_command_processor', $client['name']);
2626
$container->register($id, RunCommandProcessor::class)
27-
->addArgument('%kernel.project_dir%', $client['timeout'])
27+
->addArgument('%kernel.project_dir%')
28+
->addArgument($client['timeout'])
2829
->addTag('enqueue.processor', [
2930
'client' => $client['name'],
3031
'command' => $client['command_name'] ?? Commands::RUN_COMMAND,

‎pkg/async-event-dispatcher/.travis.yml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ language: php
88
php:
99
- '7.1'
1010
- '7.2'
11+
- '7.3'
12+
- '7.4'
1113

1214
cache:
1315
directories:

‎pkg/dbal/.travis.yml‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ language: php
88
php:
99
- '7.1'
1010
- '7.2'
11+
- '7.3'
12+
- '7.4'
1113

1214
cache:
1315
directories:

0 commit comments

Comments
 (0)