バギーなのでジョブキュー無効化
This commit is contained in:
parent
b7b82456d8
commit
8a57f490ce
|
@ -79,9 +79,6 @@ async function workerMain() {
|
||||||
// start server
|
// start server
|
||||||
await require('./server').default();
|
await require('./server').default();
|
||||||
|
|
||||||
// start processor
|
|
||||||
require('./queue').default();
|
|
||||||
|
|
||||||
// Send a 'ready' message to parent process
|
// Send a 'ready' message to parent process
|
||||||
process.send('ready');
|
process.send('ready');
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,28 +1,8 @@
|
||||||
import * as Queue from 'bee-queue';
|
|
||||||
|
|
||||||
import config from '../config';
|
|
||||||
import http from './processors/http';
|
import http from './processors/http';
|
||||||
import { ILocalUser } from '../models/user';
|
import { ILocalUser } from '../models/user';
|
||||||
|
|
||||||
const queue = new Queue('misskey', {
|
|
||||||
redis: {
|
|
||||||
port: config.redis.port,
|
|
||||||
host: config.redis.host,
|
|
||||||
password: config.redis.pass
|
|
||||||
},
|
|
||||||
|
|
||||||
removeOnSuccess: true,
|
|
||||||
removeOnFailure: true,
|
|
||||||
getEvents: false,
|
|
||||||
sendEvents: false,
|
|
||||||
storeJobs: false
|
|
||||||
});
|
|
||||||
|
|
||||||
export function createHttpJob(data: any) {
|
export function createHttpJob(data: any) {
|
||||||
return queue.createJob(data)
|
return http(data, () => {});
|
||||||
//.retries(4)
|
|
||||||
//.backoff('exponential', 16384) // 16s
|
|
||||||
.save();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export function deliver(user: ILocalUser, content: any, to: any) {
|
export function deliver(user: ILocalUser, content: any, to: any) {
|
||||||
|
@ -33,7 +13,3 @@ export function deliver(user: ILocalUser, content: any, to: any) {
|
||||||
to
|
to
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
export default function() {
|
|
||||||
queue.process(128, http);
|
|
||||||
}
|
|
||||||
|
|
Loading…
Reference in New Issue