diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2018-04-07 07:19:30 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2018-04-07 07:19:30 +0900 |
| commit | 494597236cea4a40bddd9655b6506464df053bfe (patch) | |
| tree | a9b468a88a34cd37ee9527c433188178b8a0af12 /src/queue/index.ts | |
| parent | Fix bug (diff) | |
| download | sharkey-494597236cea4a40bddd9655b6506464df053bfe.tar.gz sharkey-494597236cea4a40bddd9655b6506464df053bfe.tar.bz2 sharkey-494597236cea4a40bddd9655b6506464df053bfe.zip | |
投稿に関しては論理削除するように
処理をシンプルにするため
Diffstat (limited to 'src/queue/index.ts')
| -rw-r--r-- | src/queue/index.ts | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts index 691223de2d..4aa1dc032d 100644 --- a/src/queue/index.ts +++ b/src/queue/index.ts @@ -1,7 +1,6 @@ import { createQueue } from 'kue'; import config from '../config'; -import db from './processors/db'; import http from './processors/http'; const queue = createQueue({ @@ -19,10 +18,6 @@ export function createHttp(data) { .backoff({ delay: 16384, type: 'exponential' }); } -export function createDb(data) { - return queue.create('db', data); -} - export function deliver(user, content, to) { return createHttp({ type: 'deliver', @@ -33,8 +28,6 @@ export function deliver(user, content, to) { } export default function() { - queue.process('db', db); - /* 256 is the default concurrency limit of Mozilla Firefox and Google Chromium. |