search

weyoss / redis-smq

A simple high-performance Redis message queue for Node.js.
MIT License
588 stars 64 forks source link

Connection forcefully ended and command aborted. #26

Closed JohnLou closed 5 years ago

JohnLou commented 5 years ago

AbortError: Connection forcefully ended and command aborted. It might have been processed. at RedisClient.flush_and_error (/data/site/quan-share/node_modules/redis/index.js:357:23) at RedisClient.end (/data/site/quan-share/node_modules/redis/lib/extendedApi.js:51:14) at handler (/data/site/quan-share/node_modules/redis-smq/src/scheduler.js:180:24) at Object.stop (/data/site/quan-share/node_modules/redis-smq/src/scheduler.js:193:20) at Object.shutdown (/data/site/quan-share/node_modules/redis-smq/src/dispatcher.js:390:27) at Producer.shutdown (/data/site/quan-share/node_modules/redis-smq/src/producer.js:62:25) at producer.produce (/data/site/quan-share/utils/log.js:135:16) at Command.redisClientInstance.lpush [as callback] (/data/site/quan-share/node_modules/redis-smq/src/dispatcher.js:431:25) at normal_reply (/data/site/quan-share/node_modules/redis/index.js:721:21) at RedisClient.return_reply (/data/site/quan-share/node_modules/redis/index.js:819:9) at JavascriptRedisParser.returnReply (/data/site/quan-share/node_modules/redis/index.js:192:18) at JavascriptRedisParser.execute (/data/site/quan-share/node_modules/redis-parser/lib/parser.js:574:12) at Socket. (/data/site/quan-share/node_modules/redis/index.js:274:27) at emitOne (events.js:116:13) at Socket.emit (events.js:211:7) at addChunk (_stream_readable.js:263:12) at readableAddChunk (_stream_readable.js:250:11) at Socket.Readable.push (_stream_readable.js:208:10) at TCP.onread (net.js:607:20)