|
|
@ -95,8 +95,9 @@ export class MessageQueue implements MessageQueueInterface {
|
|
|
|
// Open groups
|
|
|
|
// Open groups
|
|
|
|
if (message instanceof OpenGroupMessage) {
|
|
|
|
if (message instanceof OpenGroupMessage) {
|
|
|
|
// No queue needed for Open Groups; send directly
|
|
|
|
// No queue needed for Open Groups; send directly
|
|
|
|
const rawMessage = MessageUtils.toRawMessage(message);
|
|
|
|
const rawMessage = MessageUtils.toRawMessage(message.group, message);
|
|
|
|
await MessageSender.send(message);
|
|
|
|
await MessageSender.send(message);
|
|
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|