Comments (13)
You test script has finally helped me to reproduce the bug.
This bug has been fixed and was related to garbage collector.
A new package version is out. Please upgrade.
Thank you for helping to make this application better!
from redis-smq.
I post my test script to https://github.com/JohnLou/try-smq . My steps and logs in log.txt.
from redis-smq.
I think it is not a bug.
When a message is unacknowledged because of an error, depending on options.messageRetryThreshold
, the message is immediately requeued or moved to DL queue.
After that the message is requeued it is consumed by any available consumer instance, given many instances.
So in your case, I guess, each time the message is queued, it is delivered to a consumer, an error occurs, it is re-queued again and delivered to another consumer, once again the same error occurs and so on until the options.messageRetryThreshold
is exceeded, then it is moved to DL Queue.
This happens in such speed that it gives you an impression that the message is sent to all consumers but in fact it is delivered only to one given consumer instance at a time.
If you still believe that this issue is a bug, please provide enough details to reproduced it.
from redis-smq.
Thanks for your reply.
That's right "When the message is requeued it is consumed immediately by any other available consumer instance". I have a question for "requeued" and "any other available consumer instance". Is "requeued" means the message well send to another queue (I means the "queueName" property of msq.Consumer).
I have some Consumer extends msq.Consumer, and each of them running single instance.
class UserLoginConsumer extends smq.Consumer {
consume(msg, cb) {
log.debug('user login consumer: ' + JSON.stringify(msg));
.....
// if error occurs
setTimeout(()=>{return cb && cb(err);}, DELAY_TIMES);
}
}
UserLoginConsumer.queueName = QUEUES.USER_LOGIN_MESSAGE_QUEUE;
/***
- order queue to db.
*/
class CpsOrderFetchConsumer extends smq.Consumer {
consume(msg, cb) {
log.debug('fetch order consumer: ' + JSON.stringify(msg));
if(msg && msg.type){
switch (msg.type) {
case HAOQUAN_MSQ.PDD_CPS_ORDER.type:
// for test error
const _err='PDD order send to db error. Wait ['+DELAY_TIMES+'] to requeue.';
log.debug(_err);
setTimeout(()=>{
return cb(_err);
}, DELAY_TIMES);
break;
....
}
}
CpsOrderFetchConsumer.queueName = QUEUES.CPS_ORDER_FETCH_QUEUE;
/***
- order process in queue.
*/
class OrderProcessConsumer extends smq.Consumer {
consume(msg, cb) {
log.debug('order process consumer: ' + JSON.stringify(msg));
.....
// if error occurs
setTimeout(()=>{return cb && cb(err);}, DELAY_TIMES);
}
}
OrderProcessConsumer.queueName = QUEUES.ORDER_PROCESS_QUEUE;
This is not fixed,but try several more times.
from redis-smq.
That's right "When the message is requeued it is consumed immediately by any other available consumer instance". I have a question for "requeued" and "any other available consumer instance". Is "requeued" means the message well send to another queue (I means the "queueName" property of msq.Consumer).
Let me make it clear for you.
There can be many queues. A queue can have many consumers and many producers. Each queue has a system generated queue named Dead-Letter Queue for storing messages that can no longer be delivered to a consumer.
Let's suppose we have:
- 2 queues [Q1, Q2].
- 2 DL queues [DLQ1] for Q1 and [DLQ2] for Q2.
- Each queue has one producer: [P1] for Q1 and [P2] for Q2
- Each queue has 2 consumers: [C1.1, C1.2] for Q1 and [C2.1, C2.2] for Q2
Then:
- Producer P1 produced a message M1 to the queue Q1.
- The message M1 is delivered to either C1.1 or C1.2.
- We consider that the message M1 has been delivered to consumer C1.2.
- While consuming the message M1 an error occurs, the consumer C1.2 unacknowledges the message by calling
cb(err)
. - The messsage M1 is pushed back (requeued) to the queue Q1.
- The consumer C1.1 takes this time the message M1.
- Once again an error occurs, consumer C1.1 unacknowledges the message by calling
cb(err)
. - The messsage M1 is pushed back (requeued) to the queue Q1.
- The message is delivered to consumer C1.2.
- And so on until
options.messageRetryThreshold
is exceeded, then the message is moved to DLQ1 beacause it can no longer be processed.
from redis-smq.
I highly suspect that you have something wrong somewhere. Please debug every peace of your code to figure out what is wrong.
This issue can not be reproduced.
Here is a simple test that demonstrates the above:
HelloQueueConsumer:
// Save this script to hello-queue-consumer.js
'use strict';
const redisSMQ = require('redis-smq');
const Consumer = redisSMQ.Consumer;
class HelloQueueConsumer extends Consumer {
/**
*
* @param message
* @param cb
*/
consume(message, cb) {
cb(new Error('hello error'));
}
}
HelloQueueConsumer.queueName = 'hello_queue';
const consumer = new HelloQueueConsumer();
consumer.run();
TestQueueConsumer:
// Save this script to test-queue-consumer.js
'use strict';
const redisSMQ = require('redis-smq');
const Consumer = redisSMQ.Consumer;
class TestQueueConsumer extends Consumer {
/**
*
* @param message
* @param cb
*/
consume(message, cb) {
cb(new Error('test error'));
}
}
TestQueueConsumer.queueName = 'test_queue';
const consumer = new TestQueueConsumer();
consumer.run();
Producers:
// Save this script to producers.js
'use strict';
const Producer = require('redis-smq').Producer;
/**
*
* @param producer
* @param message
* @param n
* @param cb
*/
function produceNTimes(producer, message, n, cb) {
n -= 1;
if (n >= 0) {
message.sequenceId = n;
producer.produce(message, (err) => {
if (err) cb(err);
else produceNTimes(producer, message, n, cb);
});
} else cb();
}
const producer1 = new Producer('test_queue');
produceNTimes(producer1, { from: 'test_queue', hello: 'world' }, 100, (err) => {
if (err) throw err;
else {
console.log('Produced successfully!');
producer1.shutdown();
}
});
const producer2 = new Producer('hello_queue');
produceNTimes(producer2, { from: 'hello_queue', hello: 'world' }, 100, (err) => {
if (err) throw err;
else {
console.log('Produced successfully!');
producer2.shutdown();
}
});
package.json
{
"name": "redis-smq-example",
"author": "Weyoss <[email protected]>",
"license": "MIT",
"private": true,
"dependencies": {
"redis": "2.7.1",
"redis-smq": "1.0.x"
}
}
Save hello-queue-consumer.js, test-queue-consumer.js, producers.js and package.json in some folder in your disk then run:
Open a console, go to the path of your folder and run:
npm install
node test-queue-consumer.js
In another console run:
node hello-queue-consumer.js
In another console run:
node producers.js
Wait for some time until the messages are produced and consumed then open a console and run:
testuser@vnode587:~/projects/test$ redis-cli
127.0.0.1:6379> scan 0
1) "0"
2) 1) "redis-smq-default|@6.2"
2) "redis-smq-default|@2.1"
3) "redis-smq-default|@3.1|test_queue"
4) "redis-smq-default|@1.3|hello_queue"
5) "redis-smq-default|@6.3"
6) "redis-smq-default|@3.1|hello_queue"
7) "redis-smq-default|@6.1"
8) "redis-smq-default|@1.3|test_queue"
127.0.0.1:6379> llen redis-smq-default|@1.3|hello_queue
(integer) 100
127.0.0.1:6379> llen redis-smq-default|@1.3|test_queue
(integer) 100
127.0.0.1:6379> lrange redis-smq-default|@1.3|hello_queue 0 99
1) "{\"uuid\":\"28fabff6-b238-4f99-995b-3d4aea247fdd\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":0},\"time\":1524755318844,\"ttl\":0,\"error\":{}}"
2) "{\"uuid\":\"34c53cc1-b9c2-4162-b1cb-e380b80408af\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":1},\"time\":1524755318844,\"ttl\":0,\"error\":{}}"
3) "{\"uuid\":\"130ae3d2-d377-43a0-93d3-43317716ed9e\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":2},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
4) "{\"uuid\":\"2fcb40e6-8b07-4a09-b6ea-d76ab71d63bb\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":3},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
5) "{\"uuid\":\"ea8b7d57-f15a-4c37-b0ac-016ac8e1f600\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":4},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
6) "{\"uuid\":\"319dae8d-5940-445b-90af-65b1634c1226\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":5},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
7) "{\"uuid\":\"24ccba92-cb41-48d9-b2f1-74ef8bb68e81\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":6},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
8) "{\"uuid\":\"c30222a4-6bad-47b6-939d-694792d2db47\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":7},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
9) "{\"uuid\":\"2404f995-1126-444f-a4d5-7ce24ce2bafb\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":8},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
10) "{\"uuid\":\"a3b4c981-e1d0-49d6-8f3b-20b93f69e9e4\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":9},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
11) "{\"uuid\":\"202075c0-63fd-4237-b154-6adabebd4da4\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":10},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
12) "{\"uuid\":\"8b221bb0-f31b-453e-8e51-26be6ca29a55\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":11},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
13) "{\"uuid\":\"b0aa313f-8250-41f7-b174-1290b37bf5ae\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":12},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
14) "{\"uuid\":\"148b4cf1-6fea-4929-aed4-28bea7ecbb49\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":13},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
15) "{\"uuid\":\"6bd9984a-53e0-4a06-bf3d-b48430b97f5f\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":14},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
16) "{\"uuid\":\"22fddb18-45e4-4a41-a991-a274d34c3e05\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":15},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
17) "{\"uuid\":\"ab30319e-e0ac-47d7-b583-6e90a3a8a655\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":16},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
18) "{\"uuid\":\"8c0ee7bd-4b7c-4e0a-8205-8ea8ac9bf7f0\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":17},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
19) "{\"uuid\":\"29b59705-a006-4c33-aa31-1dbe9d2cd9ab\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":18},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
20) "{\"uuid\":\"01740d91-f77c-4867-9369-029eeba2e0f4\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":19},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
21) "{\"uuid\":\"c68958a3-7905-4e9f-9a65-14875f4a7aa7\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":20},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
22) "{\"uuid\":\"df61e3b2-add0-4a42-ab4d-9291fe87103b\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":21},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
23) "{\"uuid\":\"d9f5e287-bb55-41c5-9edd-9357ad0d0087\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":22},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
24) "{\"uuid\":\"5962817c-a18e-414f-b8de-0e80452b827d\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":23},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
25) "{\"uuid\":\"ebe81bd4-3919-4d84-841f-41e52daefaca\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":24},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
26) "{\"uuid\":\"17c719a6-dcb3-4b07-b45d-24d1b5c7b8e8\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":25},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
27) "{\"uuid\":\"d5cfc1aa-9d98-42b8-a976-2562b4132575\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":26},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
28) "{\"uuid\":\"7d870a54-e027-4efe-9a4c-fdcf8d491816\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":27},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
29) "{\"uuid\":\"f4d437c7-9567-482d-aa04-a624297a0301\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":28},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
30) "{\"uuid\":\"addbb3d6-810e-47e4-a13e-72a66db9f4e0\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":29},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
31) "{\"uuid\":\"e8d133ab-6f26-4e20-9d87-672f5104e839\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":30},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
32) "{\"uuid\":\"1d99702c-e175-4a7f-809c-9005ef5cf03d\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":31},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
33) "{\"uuid\":\"f45f261a-7b90-4592-ae99-8a66ff9f31ad\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":32},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
34) "{\"uuid\":\"cdd39ccc-1b9c-43b7-855f-b0e5ddeaa038\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":33},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
35) "{\"uuid\":\"77a19ca3-92e9-4981-9cb6-b685f87c0e70\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":34},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
36) "{\"uuid\":\"5a515a0d-8e7c-499c-a8db-a79e486580c5\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":35},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
37) "{\"uuid\":\"7882d45c-12c3-4eeb-ac1f-4bfcd0598aa7\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":36},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
38) "{\"uuid\":\"67e64b03-7028-43db-94a3-efbf6440a0c1\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":37},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
39) "{\"uuid\":\"dbf8a0f9-2976-486c-a39b-f6521c52b3e8\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":38},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
40) "{\"uuid\":\"948fc389-6d57-449b-92f9-84715f578519\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":39},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
41) "{\"uuid\":\"eaa97122-87ba-458f-abcd-e188c7bd4e73\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":40},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
42) "{\"uuid\":\"dce3a598-8846-4778-8947-b94e9188fcd2\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":41},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
43) "{\"uuid\":\"44d0edb0-d0cc-4463-95ec-b9e1cf6bd25f\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":42},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
44) "{\"uuid\":\"5fbd144f-8c21-412a-83ae-4b54cc1642d9\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":43},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
45) "{\"uuid\":\"e7564423-b675-40eb-9000-5ad589f2e6da\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":44},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
46) "{\"uuid\":\"311bb704-cefe-4d12-9e1c-185824573849\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":45},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
47) "{\"uuid\":\"74d09ce3-0052-42dc-b925-eb400d6b014a\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":46},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
48) "{\"uuid\":\"84502f5b-d95e-46b4-a1ab-a4654032d862\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":47},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
49) "{\"uuid\":\"793f512c-1a0f-4ce8-8c3e-1ef78bdf3fcc\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":48},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
50) "{\"uuid\":\"ba315981-cf08-41e7-a8ea-e6d37d684bf0\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":49},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
51) "{\"uuid\":\"7aaefbb9-26c1-4186-b9f1-371d6a571621\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":50},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
52) "{\"uuid\":\"0d33f7d8-4cd0-4cd2-bb5f-725ace8a77f5\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":51},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
53) "{\"uuid\":\"771138f6-dcea-48d6-80d6-63ca38540cb3\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":52},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
54) "{\"uuid\":\"066587d6-a8af-4b75-b3ab-3d80044b7395\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":53},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
55) "{\"uuid\":\"609a6c92-b02e-4880-b765-456f44c40445\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":54},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
56) "{\"uuid\":\"cb75e582-0bac-4bb5-84e3-3295f3bbf5e6\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":55},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
57) "{\"uuid\":\"337b4f85-7b72-4c8a-9f04-9e57562e2d02\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":56},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
58) "{\"uuid\":\"d4e58d8d-21b9-488b-b135-2509986f1f00\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":57},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
59) "{\"uuid\":\"f9b6e440-077c-49c5-9f37-a70e171128cb\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":58},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
60) "{\"uuid\":\"a53397df-51a6-4043-97d7-8d92199d8c61\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":59},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
61) "{\"uuid\":\"8d34d807-c122-4d4a-848c-f00e62f6264b\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":60},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
62) "{\"uuid\":\"9658fe95-5722-4b5c-88c7-381ac5815281\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":61},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
63) "{\"uuid\":\"befa5bb2-d34a-4418-8a00-44dec8080efa\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":62},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
64) "{\"uuid\":\"3c508894-efff-4fd2-8cc2-c2c9edf6badf\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":63},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
65) "{\"uuid\":\"9523282f-70e2-447b-97cc-ed92dd19b131\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":64},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
66) "{\"uuid\":\"4d7a439a-c9d9-4a5a-88b9-e2f4c022910f\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":65},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
67) "{\"uuid\":\"f0e115b8-2aa7-4b93-871a-faa2e5a779da\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":66},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
68) "{\"uuid\":\"3b4ee4e4-be55-454b-9d3d-5e427901e161\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":67},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
69) "{\"uuid\":\"9bd4e43a-6270-4860-b9dd-3771ed63e0aa\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":68},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
70) "{\"uuid\":\"10bba2eb-ade4-4127-a9ff-cff07c1046bf\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":69},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
71) "{\"uuid\":\"0fce6942-fcde-4966-be4b-4c005e8eefa6\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":70},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
72) "{\"uuid\":\"c0f9db79-8e23-462d-9fb8-a48ea55aad0f\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":71},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
73) "{\"uuid\":\"1b27ea32-a3aa-407f-a8ff-0cfed4bc2699\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":72},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
74) "{\"uuid\":\"1795cf30-fa72-4822-9b54-5cf7f90f3dd8\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":73},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
75) "{\"uuid\":\"b9941a24-abd3-407e-b082-7cf7bbb57c7d\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":74},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
76) "{\"uuid\":\"5d18cfbe-a374-4ac4-a428-7283d45fc7e5\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":75},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
77) "{\"uuid\":\"bcb958fe-daba-475b-bc72-91c9a2c27b5f\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":76},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
78) "{\"uuid\":\"7a6833f1-b2a2-41ab-99a2-4d2459fc747b\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":77},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
79) "{\"uuid\":\"e0440a1c-69eb-407c-8225-a162adffcb35\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":78},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
80) "{\"uuid\":\"ffda6049-ae0d-49a7-a6b5-b8338e07d787\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":79},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
81) "{\"uuid\":\"9eeeb42d-bc78-4d67-a952-775634d758d4\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":80},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
82) "{\"uuid\":\"b69206f2-62cb-4a7e-9096-8e07921611d8\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":81},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
83) "{\"uuid\":\"76a16f91-3c21-4eee-816c-3fd3c66293a1\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":82},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
84) "{\"uuid\":\"1e4b4bd4-c242-4306-be81-d41749dd4f40\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":83},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
85) "{\"uuid\":\"412d3654-eac9-4aa1-8ed8-e7c3a7b6d5c5\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":84},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
86) "{\"uuid\":\"45d0ea94-deb3-4922-a0f6-b36828622459\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":85},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
87) "{\"uuid\":\"b20acddb-2cb1-408f-9aac-c0e0900436c2\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":86},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
88) "{\"uuid\":\"db88b018-2ade-4047-b3e9-2091a573e6e3\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":87},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
89) "{\"uuid\":\"26e3aaee-9e49-41a3-b506-407e499de911\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":88},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
90) "{\"uuid\":\"f44151b5-1aa6-4545-a31d-665510faa447\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":89},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
91) "{\"uuid\":\"31e156bf-46c4-43d6-9a1f-2cebae0c523f\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":90},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
92) "{\"uuid\":\"6f8ab4ed-10e3-4565-8de0-b6c1b3083f1a\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":91},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
93) "{\"uuid\":\"af72ff12-21fa-4a01-9ff6-c07c029f3095\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":92},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
94) "{\"uuid\":\"b3e4676e-7e51-4588-94cf-709ad4a1c3a5\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":93},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
95) "{\"uuid\":\"8c5e23e1-bb67-4756-ac70-65244c47d76a\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":94},\"time\":1524755318827,\"ttl\":0,\"error\":{}}"
96) "{\"uuid\":\"7d784f9a-4adf-4f0a-a1fa-fdd4c11ef39d\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":95},\"time\":1524755318825,\"ttl\":0,\"error\":{}}"
97) "{\"uuid\":\"48c5bbba-0708-4a48-9f39-d6b1a3766ca9\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":96},\"time\":1524755318823,\"ttl\":0,\"error\":{}}"
98) "{\"uuid\":\"39328528-2db7-4a72-bd36-7a5e939a9ad9\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":97},\"time\":1524755318822,\"ttl\":0,\"error\":{}}"
99) "{\"uuid\":\"c57d3b69-4514-43ed-a957-43a7f4f2b843\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":98},\"time\":1524755318820,\"ttl\":0,\"error\":{}}"
100) "{\"uuid\":\"ec5ac10a-c30e-4299-b9db-4729972512c1\",\"attempts\":4,\"data\":{\"from\":\"hello_queue\",\"hello\":\"world\",\"sequenceId\":99},\"time\":1524755318807,\"ttl\":0,\"error\":{}}"
127.0.0.1:6379> lrange redis-smq-default|@1.3|test_queue 0 99
1) "{\"uuid\":\"af18595c-98a5-4686-bb74-4ea5f5063ae7\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":0},\"time\":1524755318846,\"ttl\":0,\"error\":{}}"
2) "{\"uuid\":\"1e06059e-b73d-4fd2-b10b-d8b4a26c726b\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":1},\"time\":1524755318846,\"ttl\":0,\"error\":{}}"
3) "{\"uuid\":\"d12c3c40-408d-4ade-b633-6eab48f0cf39\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":2},\"time\":1524755318845,\"ttl\":0,\"error\":{}}"
4) "{\"uuid\":\"7cfa5860-fb9d-4b2f-8030-ec41e07c7299\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":3},\"time\":1524755318845,\"ttl\":0,\"error\":{}}"
5) "{\"uuid\":\"08285ad2-504e-49c9-9bfb-f100dceca017\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":4},\"time\":1524755318845,\"ttl\":0,\"error\":{}}"
6) "{\"uuid\":\"f07fb5e8-00a9-43aa-8e4f-90039db95e19\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":5},\"time\":1524755318844,\"ttl\":0,\"error\":{}}"
7) "{\"uuid\":\"c1cd505b-09d2-48ae-840f-8ff97b6233e9\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":6},\"time\":1524755318844,\"ttl\":0,\"error\":{}}"
8) "{\"uuid\":\"3c35921c-326f-4509-b6cd-e703afd375f0\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":7},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
9) "{\"uuid\":\"8c5a53c8-30e8-4744-9f23-c582f97c870f\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":8},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
10) "{\"uuid\":\"7e888092-c4ab-424c-aaad-33feff6365e5\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":9},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
11) "{\"uuid\":\"5f559530-dec1-46fb-b209-775b9ab36d21\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":10},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
12) "{\"uuid\":\"cbd65c17-e95a-4177-9066-6d3d258ba6f2\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":11},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
13) "{\"uuid\":\"fdf58501-52cf-4ede-9237-acdc7be8b658\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":12},\"time\":1524755318843,\"ttl\":0,\"error\":{}}"
14) "{\"uuid\":\"5dda1f07-54ea-488d-ac52-74600a4086e3\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":13},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
15) "{\"uuid\":\"a47747cf-f5f4-40a8-a570-68f0ca0c1a95\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":14},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
16) "{\"uuid\":\"5f35b3b3-8b62-4e6e-87f5-b63d3e652330\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":15},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
17) "{\"uuid\":\"3c88d3c6-f11b-4017-aa89-96cf2388634b\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":16},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
18) "{\"uuid\":\"37eb250f-5561-4e7b-ae53-bf3adda3aa57\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":17},\"time\":1524755318842,\"ttl\":0,\"error\":{}}"
19) "{\"uuid\":\"2396f797-2ee2-4c6b-96ef-6e9813145bf2\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":18},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
20) "{\"uuid\":\"111e2341-f539-4e06-af1b-1fee19d978e6\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":19},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
21) "{\"uuid\":\"73e0d0ab-edc9-42f6-9878-4291efd4f43d\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":20},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
22) "{\"uuid\":\"f8faf6f8-47df-4525-ac69-326df744099e\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":21},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
23) "{\"uuid\":\"c1448c39-e14d-4485-ad56-23a5ce51da8a\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":22},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
24) "{\"uuid\":\"ed1ac9de-e312-4fe8-b06f-238f15b714b4\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":23},\"time\":1524755318841,\"ttl\":0,\"error\":{}}"
25) "{\"uuid\":\"1e485f17-2e66-49f8-848c-7bf814fae73c\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":24},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
26) "{\"uuid\":\"2cb92540-67ce-4a1f-912a-6a5cb3b56492\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":25},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
27) "{\"uuid\":\"1e0579cd-9d95-492e-8636-c8b0c0be50d7\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":26},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
28) "{\"uuid\":\"da387a82-ca15-4c15-9d19-c8376d94ea98\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":27},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
29) "{\"uuid\":\"e49386a3-d8d5-4e10-aac3-8ad649ea0d04\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":28},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
30) "{\"uuid\":\"f4684105-39e9-40e7-aa7e-207f81d53897\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":29},\"time\":1524755318840,\"ttl\":0,\"error\":{}}"
31) "{\"uuid\":\"1bcf7f09-1738-41c3-9ade-64cc14b5d0b3\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":30},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
32) "{\"uuid\":\"d2bd7333-8066-4dda-b30d-916ce8d94620\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":31},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
33) "{\"uuid\":\"b6acb40d-9390-4aec-b09c-15a786428074\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":32},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
34) "{\"uuid\":\"72b2b2f2-ebb6-4165-8dfe-0bb9855ce773\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":33},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
35) "{\"uuid\":\"335ae77a-0fa6-4867-b4be-520355d28277\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":34},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
36) "{\"uuid\":\"0d921e22-e2de-4c53-bcac-cbd5de69a829\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":35},\"time\":1524755318839,\"ttl\":0,\"error\":{}}"
37) "{\"uuid\":\"f69f9eac-a618-4e7d-9935-a86ebe0e3ca2\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":36},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
38) "{\"uuid\":\"cf2631fc-6f36-41c1-964e-e64072a6539d\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":37},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
39) "{\"uuid\":\"c3acbfbb-731f-466c-9890-5a61a8ea2a6d\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":38},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
40) "{\"uuid\":\"9e571edd-537c-466d-a986-3f0e398468e6\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":39},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
41) "{\"uuid\":\"36867eaa-f6f8-4c68-9a69-5e78010a5e77\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":40},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
42) "{\"uuid\":\"49be9903-9e8a-41c5-9d49-5df4ae70523e\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":41},\"time\":1524755318838,\"ttl\":0,\"error\":{}}"
43) "{\"uuid\":\"ee871fef-c7da-495e-94da-1f65993912f8\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":42},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
44) "{\"uuid\":\"ddd7d741-0fae-43de-9ed9-b89f0cc85f91\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":43},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
45) "{\"uuid\":\"92b40c89-a4bf-481a-8bb7-ebf17ecb8467\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":44},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
46) "{\"uuid\":\"a2a3f7d3-0346-49cb-ad41-1264abb00ad3\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":45},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
47) "{\"uuid\":\"86f0514d-1069-416b-9012-68d4c4f1dc42\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":46},\"time\":1524755318837,\"ttl\":0,\"error\":{}}"
48) "{\"uuid\":\"9a869aca-bfd1-4898-b8e8-b1fa4ce670d0\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":47},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
49) "{\"uuid\":\"eedbe07a-0e28-48b3-a4df-887431b1f798\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":48},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
50) "{\"uuid\":\"df6fb4a2-69a0-4390-8932-39b8d0f90155\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":49},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
51) "{\"uuid\":\"4c6d1213-a0e6-4174-bac1-e728f3809e14\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":50},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
52) "{\"uuid\":\"778e0356-3267-423c-b7b2-a0b416b63cba\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":51},\"time\":1524755318836,\"ttl\":0,\"error\":{}}"
53) "{\"uuid\":\"b91ff7ab-6877-4471-ad02-17524f6a53d8\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":52},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
54) "{\"uuid\":\"f2e6d58b-72e7-4ac6-af2b-19209117aaed\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":53},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
55) "{\"uuid\":\"eaaa8842-2907-4377-9ba5-1d8205db5690\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":54},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
56) "{\"uuid\":\"9d8f766c-8604-4a8e-878e-2704e09c5b22\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":55},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
57) "{\"uuid\":\"4d45bf0c-299b-495b-9872-2bc00e2d2ecd\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":56},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
58) "{\"uuid\":\"e6db6e48-d815-4cb2-8ffc-2d3379ca67f0\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":57},\"time\":1524755318835,\"ttl\":0,\"error\":{}}"
59) "{\"uuid\":\"dfb17baa-b6f0-4d55-bd3d-9c5fb931409d\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":58},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
60) "{\"uuid\":\"04622671-fcac-4fa1-a173-42023d2652c5\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":59},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
61) "{\"uuid\":\"e21aefd8-1514-4a87-be3d-a5f1d1e060de\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":60},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
62) "{\"uuid\":\"482df116-64b2-4338-a342-a3db3e536419\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":61},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
63) "{\"uuid\":\"e270e563-b547-47a2-a6bf-b4400c71af68\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":62},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
64) "{\"uuid\":\"2cb7cb63-f3ef-4b3e-87f9-d1b9ee05a634\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":63},\"time\":1524755318834,\"ttl\":0,\"error\":{}}"
65) "{\"uuid\":\"6b483977-f78c-4095-9f09-56933af85c12\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":64},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
66) "{\"uuid\":\"c4db9b7b-118c-4e67-b69b-8a09ffbd9d34\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":65},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
67) "{\"uuid\":\"aa6c67cd-2c92-4fa8-aba1-ca39fd745b4a\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":66},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
68) "{\"uuid\":\"e54ae30b-a0b8-425e-9f44-c5c67ff1582a\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":67},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
69) "{\"uuid\":\"034640c9-4430-4b67-8396-e6e65b0d166f\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":68},\"time\":1524755318833,\"ttl\":0,\"error\":{}}"
70) "{\"uuid\":\"52837248-7b9a-4ef2-b574-9bed1572708c\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":69},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
71) "{\"uuid\":\"432073e1-7dd9-4bf3-947c-f62e33f1596f\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":70},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
72) "{\"uuid\":\"4c50b604-54d0-4d24-bc5d-0eff679e7e96\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":71},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
73) "{\"uuid\":\"7120892a-34e4-4111-a21a-4e6d1f5ed1aa\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":72},\"time\":1524755318832,\"ttl\":0,\"error\":{}}"
74) "{\"uuid\":\"b3e67c86-bc1b-4e1b-9fab-944389756ba8\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":73},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
75) "{\"uuid\":\"0c5a782e-7783-4932-9474-2fd12c8a39cf\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":74},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
76) "{\"uuid\":\"4ece9969-5ba0-4ab4-a327-6e4473085157\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":75},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
77) "{\"uuid\":\"3a9358a9-d6c9-4f82-88f9-59aa0a06577b\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":76},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
78) "{\"uuid\":\"3453e9b2-f10b-4d57-9a5f-d6790f5e3278\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":77},\"time\":1524755318831,\"ttl\":0,\"error\":{}}"
79) "{\"uuid\":\"e177c29c-ac07-4e45-a652-08f8d789b7d8\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":78},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
80) "{\"uuid\":\"fd70630c-0b9b-45df-8b77-bbeaf2804151\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":79},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
81) "{\"uuid\":\"73bd5f45-c863-4639-ac0c-32317f470f75\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":80},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
82) "{\"uuid\":\"93c96f23-9013-4198-b929-c83fec10b03c\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":81},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
83) "{\"uuid\":\"26f677d1-4cb6-46db-9bca-200ee01ba3b1\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":82},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
84) "{\"uuid\":\"2a89c129-884e-4acd-b89c-2776d8d97f71\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":83},\"time\":1524755318830,\"ttl\":0,\"error\":{}}"
85) "{\"uuid\":\"34d7249d-9f0a-4395-93c2-c858f3516bbd\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":84},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
86) "{\"uuid\":\"fb225e1b-f576-4f1f-afd0-1bfe282971ff\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":85},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
87) "{\"uuid\":\"e35ab7c8-28a0-491d-83da-a130c5f0d8d8\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":86},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
88) "{\"uuid\":\"f40d696a-bc23-4ab4-8e1e-04eafa738245\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":87},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
89) "{\"uuid\":\"17e7ae8b-ae8a-497c-bbe2-d430f2843776\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":88},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
90) "{\"uuid\":\"ab8944a4-714a-47cc-ab9f-2209e29075db\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":89},\"time\":1524755318829,\"ttl\":0,\"error\":{}}"
91) "{\"uuid\":\"a816a369-203d-401c-8e23-6b8aaa5609af\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":90},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
92) "{\"uuid\":\"4c8f01fd-991f-41c7-ad3c-07bbde984f9a\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":91},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
93) "{\"uuid\":\"8f687d71-b300-4549-9f6b-c2d4014cc1e5\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":92},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
94) "{\"uuid\":\"8c4c42f6-7bde-4568-a28e-723d83aaf57f\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":93},\"time\":1524755318828,\"ttl\":0,\"error\":{}}"
95) "{\"uuid\":\"e5fac973-9aa6-4910-9dda-147770255e56\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":94},\"time\":1524755318826,\"ttl\":0,\"error\":{}}"
96) "{\"uuid\":\"3a604b56-a2df-48dc-875b-ed717350427b\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":95},\"time\":1524755318824,\"ttl\":0,\"error\":{}}"
97) "{\"uuid\":\"78518ed0-5311-4011-a913-c73ac987f0ec\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":96},\"time\":1524755318822,\"ttl\":0,\"error\":{}}"
98) "{\"uuid\":\"6c775841-92d5-4fec-ae23-6ff4b42a0b29\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":97},\"time\":1524755318821,\"ttl\":0,\"error\":{}}"
99) "{\"uuid\":\"e42c9250-cb40-4a36-b34c-520f54b7dfe2\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":98},\"time\":1524755318819,\"ttl\":0,\"error\":{}}"
100) "{\"uuid\":\"66d6db67-fc36-4308-acba-43a017bdb87a\",\"attempts\":4,\"data\":{\"from\":\"test_queue\",\"hello\":\"world\",\"sequenceId\":99},\"time\":1524755318807,\"ttl\":0,\"error\":{}}"
127.0.0.1:6379>
from redis-smq.
You're very clear about it. I can understand。I have not express oneself clearly in english. Demo is good idea.
So in my case:
2 queues [Q1, Q2].
2 DL queues [DLQ1] for Q1 and [DLQ2] for Q2.
Each queue has one producer: [P1] for Q1 and [P2] for Q2
Each queue has one consumer: [C1.1] for Q1 and [C2.1] for Q2
Then:
- Producer P1 produced a message M1 to the queue Q1.
- The consumer C1.1 takes this time the message M1.
- C1.1 calling cb(err);
- In most cases M1 is requeue to Q1, but some times M1 requeue to Q2.
from redis-smq.
I have no idea about what is going on in your project but be sure that if you have something to blame it is not the message queue but your project's source code.
Debugging is your best friend.
Good luck!
from redis-smq.
Thanks for your care.
Producer produced the message to queue is OK. It occurs in requeue.
from redis-smq.
Thanks alot for your help. I can try to debuging.
from redis-smq.
Closing as resolved.
from redis-smq.
If you still having this issue or anything similar please feel free to reopen it.
from redis-smq.
Great job.
Thanks!
from redis-smq.
Related Issues (20)
- LockManagerAcquireError: could not acquire a lock. HOT 3
- consumer for all queues HOT 2
- Managed redis connection keeps throwing error HOT 3
- what is difference between setConsumeTimeout and setTTL HOT 1
- Configure retry/consume parameters on consumer side HOT 4
- Config is ignored HOT 2
- Question about Features which BullMQ Pro has (Batching, Concurrency, Sandboxed Worker and Message Handlers) HOT 3
- SyntaxError: Invalid or unexpected token on server start HOT 1
- Delete a message/process in a queue HOT 1
- Fanout to multiple subscribers question HOT 7
- Implement Reliable Pub/Sub pattern HOT 1
- Configuration is not present in the redis-smq HOT 2
- Question about QueueManager.createInstance() initialisation HOT 1
- Support for iovalkey (Valkey node client)
- [Question] How to avoid duplicated tasks? HOT 6
- LockManagerExtendError: Acquired lock could not be extended HOT 3
- random retryDelay HOT 4
- [Feature] Support option for a missing interval in the scheduler. HOT 4
- How to delete message in consumer HOT 4
- Error: ENOENT: no such file or directory, open '../lua/zpophgetrpush.lua HOT 2
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from redis-smq.