Track a list of active limbo messages. We want to access this list as both a key-value store indexed by correlation-id, and a FIFO queue ordered by date.
This needs to be deployed before switching the slayer to read from memcache, so that data is available.
| Subject | Repo | Branch | Lines +/- | |
|---|---|---|---|---|
| Implement IndexedFifoQueue for Predis | wikimedia/fundraising/php-queue | master | +243 -14 |
| Status | Subtype | Assigned | Task | ||
|---|---|---|---|---|---|
| Restricted Task | |||||
| Resolved | awight | T92922 Use the new queue wrapper for limbo, antimessage, and orphan slaying | |||
| Resolved | awight | T99018 Stop writing to ActiveMQ once orphan slaying on Redis has been tested | |||
| Restricted Task | |||||
| Resolved | awight | T99017 Orphan slayer reads from frack Redis rather than ActiveMQ | |||
| Resolved | awight | T99152 Provide access to limbo messages without knowing keys |
Looking good! Couple of issues in https://github.com/adamwight/php-queue/commit/b7082cc23d037b5471f8e1efb0c01d43dad99e4c . Side note - I tried configuring the predis backend with an array of servers and it told me the multi / exec transaction wasn't supported across an aggregated connection. Will try to get to the bottom of that, since part of the goal is to make the queue server not an SPOF.
Change 215856 had a related patch set uploaded (by Awight):
Implement IndexedFifoQueue for Predis