Skip to content

Commit 6532d1e

Browse files
committed
Updated docs
1 parent 5f4ef90 commit 6532d1e

File tree

1 file changed

+37
-2
lines changed

1 file changed

+37
-2
lines changed

docs/transport/dbal.md

+37-2
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,14 @@
22

33
The transport uses [Doctrine DBAL](http://docs.doctrine-project.org/projects/doctrine-dbal/en/latest/) library and SQL like server as a broker.
44
It creates a table there. Pushes and pops messages to\from that table.
5-
6-
**Limitations** It works only in auto ack mode hence If consumer crashes the message is lost.
75

86
* [Installation](#installation)
97
* [Init database](#init-database)
108
* [Create context](#create-context)
119
* [Send message to topic](#send-message-to-topic)
1210
* [Send message to queue](#send-message-to-queue)
11+
* [Send expiration message](#send-expiration-message)
12+
* [Send delayed message](#send-delayed-message)
1313
* [Consume message](#consume-message)
1414
* [Subscription consumer](#subscription-consumer)
1515

@@ -90,6 +90,38 @@ $message = $psrContext->createMessage('Hello world!');
9090
$psrContext->createProducer()->send($fooQueue, $message);
9191
```
9292

93+
## Send expiration message
94+
95+
```php
96+
<?php
97+
/** @var \Enqueue\Dbal\DbalContext $psrContext */
98+
/** @var \Enqueue\Dbal\DbalDestination $fooQueue */
99+
100+
$message = $psrContext->createMessage('Hello world!');
101+
102+
$psrContext->createProducer()
103+
->setTimeToLive(60000) // 60 sec
104+
//
105+
->send($fooQueue, $message)
106+
;
107+
```
108+
109+
## Send delayed message
110+
111+
```php
112+
<?php
113+
/** @var \Enqueue\Dbal\DbalContext $psrContext */
114+
/** @var \Enqueue\Dbal\DbalDestination $fooQueue */
115+
116+
$message = $psrContext->createMessage('Hello world!');
117+
118+
$psrContext->createProducer()
119+
->setDeliveryDelay(5000) // 5 sec
120+
//
121+
->send($fooQueue, $message)
122+
;
123+
````
124+
93125
## Consume message:
94126

95127
```php
@@ -102,6 +134,9 @@ $consumer = $psrContext->createConsumer($fooQueue);
102134
$message = $consumer->receive();
103135

104136
// process a message
137+
138+
$consumer->acknowledge($message);
139+
//$consumer->reject($message);
105140
```
106141

107142
## Subscription consumer

0 commit comments

Comments
 (0)