Commit Graph

30 Commits

Author SHA1 Message Date
644294c55b Add renovate.json 2023-09-01 22:26:00 +00:00
fad67d327f Allow Symfony 6 2022-02-03 18:25:17 +03:00
9d2ef8e132 Fix: Prevent message duplication 2021-07-08 18:34:17 +03:00
4fac0e066f Fix: Message must be finished only on UnrecoverableExceptionInterface 2021-07-08 18:28:54 +03:00
ed2fdebce5 Set maxRdy to 1 2021-07-08 17:44:18 +03:00
819f2c9e5d Refactoring: yaml to php di, fix directory struct 2021-06-28 11:31:47 +03:00
1f2a80f820 Non retry messages must be acknowledged 2021-06-28 11:28:39 +03:00
2b9e41a857 Merge options from dsn with passed options 2021-06-09 18:49:47 +03:00
28df682351 Create ClientConfig from incoming options 2021-06-09 18:18:56 +03:00
70c466740e Use native requeue mechanism instead of symfony/messenger resends 2021-06-09 16:55:35 +03:00
5eea27cb17 Bump nsq/nsq up to 0.6.1 2021-06-09 16:37:29 +03:00
b3719b2acf Extract receiver and sender from transport 2021-06-09 14:47:40 +03:00
564fdd2be0 Refactoring: Simplify NsqTransport::get 2021-03-11 11:10:50 +03:00
ae00cdb763 Decouple from Reader (#3) 2021-03-10 20:59:03 +03:00
167588fa44 Add container.no_preload tag to NsqTransportFactory 2021-02-28 21:53:03 +03:00
ad39fb204f Amphp (#2) 2021-02-28 21:18:03 +03:00
c6e2201237 Fix: Symfony provide delay as milliseconds, but nsq receive seconds 2021-02-15 23:18:10 +03:00
bd10eb8742 Revert json_encode 2021-02-15 22:44:22 +03:00
e824d643c9 Add delay support 2021-02-15 22:40:45 +03:00
bbbc9da3e0 Extract getMessage method from NsqTransport to NsqReceivedStamp 2021-02-15 22:16:27 +03:00
ce9d1824d9 Producer keepalive must be without timeout 2021-02-11 18:24:47 +03:00
257d09cffb Wrap socket errors to try/catch 2021-02-08 21:25:26 +03:00
c6295ab8d3 Handle Producer heartbeat messages to prevent disconnection from nsq side 2021-01-26 19:58:41 +03:00
4f0c69df3e Bump nsq to 4.0.1 2021-01-26 17:06:31 +03:00
cb9d26d6fa Upgrade to nsq/nsq:4.0 2021-01-26 15:34:09 +03:00
92b778ffe2 Don't ack on send 2021-01-20 17:57:39 +03:00
67174abca7 Fix namespace 2021-01-20 17:38:06 +03:00
32ecda0cd9 Add readme 2021-01-20 17:36:15 +03:00
b3cb1c0c32 Update for nsq/nsq:0.2 2021-01-20 17:23:18 +03:00
f33a9dc226 Initial commit 2021-01-19 20:37:32 +03:00