File tree Expand file tree Collapse file tree 2 files changed +34
-3
lines changed
Expand file tree Collapse file tree 2 files changed +34
-3
lines changed Original file line number Diff line number Diff line change @@ -152,11 +152,12 @@ while (true) {
152152 // get properties
153153 var_export($message->getProperties());
154154
155- echo sprintf('Got message 【%s】messageID[%s] topic[%s] publishTime[%s]',
155+ echo sprintf('Got message 【%s】messageID[%s] topic[%s] publishTime[%s] redeliveryCount[%d] ',
156156 $message->getPayload(),
157157 $message->getMessageId(),
158158 $message->getTopic(),
159159 $message->getPublishTime(),
160+ $message->getRedeliveryCount()
160161 ) . "\n";
161162
162163 // ...
@@ -196,6 +197,19 @@ $options->setDeadLetterPolicy(6,'persistent://public/default/demo-dead');
196197$options->setDeadLetterPolicy(6,'persistent://public/default/demo-dead','sub-name');
197198```
198199
200+ > 自动重连(仅支持消费者)
201+
202+ ``` php
203+ // start reconnect
204+ $options->setReconnectPolicy(true);
205+
206+ // Reconnect interval(seconds)
207+ $options->setReconnectPolicy(true,3);
208+
209+ // Maximum number of reconnections
210+ $options->setReconnectPolicy(true,3,100);
211+ ```
212+
199213## Reader
200214
201215``` php
@@ -260,7 +274,9 @@ $reader->close();
260274 * setSubscriptionType()
261275 * setNackRedeliveryDelay()
262276 * setReceiveQueueSize()
277+ * setDeadLetterPolicy()
263278 * setSubscriptionInitialPosition()
279+ * setReconnectPolicy()
264280* ReaderOptions
265281 * setTopic()
266282 * setAuthentication()
Original file line number Diff line number Diff line change @@ -155,11 +155,12 @@ while (true) {
155155 // get properties
156156 var_export($message->getProperties());
157157
158- echo sprintf('Got message 【%s】messageID[%s] topic[%s] publishTime[%s]',
158+ echo sprintf('Got message 【%s】messageID[%s] topic[%s] publishTime[%s] redeliveryCount[%d] ',
159159 $message->getPayload(),
160160 $message->getMessageId(),
161161 $message->getTopic(),
162- $message->getPublishTime()
162+ $message->getPublishTime(),
163+ $message->getRedeliveryCount()
163164 ) . "\n";
164165
165166 // ...
@@ -199,6 +200,19 @@ $options->setDeadLetterPolicy(6,'persistent://public/default/demo-dead');
199200$options->setDeadLetterPolicy(6,'persistent://public/default/demo-dead','sub-name');
200201```
201202
203+ > Reconnect(Only Support Consumer)
204+
205+ ``` php
206+ // start reconnect
207+ $options->setReconnectPolicy(true);
208+
209+ // Reconnect interval(seconds)
210+ $options->setReconnectPolicy(true,3);
211+
212+ // Maximum number of reconnections
213+ $options->setReconnectPolicy(true,3,100);
214+ ```
215+
202216## Reader
203217
204218``` php
@@ -265,6 +279,7 @@ $reader->close();
265279 * setReceiveQueueSize()
266280 * setDeadLetterPolicy()
267281 * setSubscriptionInitialPosition()
282+ * setReconnectPolicy()
268283* ReaderOptions
269284 * setTopic()
270285 * setAuthentication()
You can’t perform that action at this time.
0 commit comments