|
@@ -104,7 +104,7 @@ class MissionService extends CrudService {
|
|
|
async toQueue(project, data) {
|
|
async toQueue(project, data) {
|
|
|
const ch = await this.mq.conn.createChannel();
|
|
const ch = await this.mq.conn.createChannel();
|
|
|
const queue = `mission/${project}`;
|
|
const queue = `mission/${project}`;
|
|
|
- await ch.assertQueue(queue, { durable: false });
|
|
|
|
|
|
|
+ await ch.assertQueue(queue, { durable: true });
|
|
|
await ch.sendToQueue(queue, Buffer.from(data));
|
|
await ch.sendToQueue(queue, Buffer.from(data));
|
|
|
await ch.close();
|
|
await ch.close();
|
|
|
}
|
|
}
|
