replace corrected messages in decryption queue
This commit is contained in:
parent
f99f21ab9b
commit
60588af825
|
@ -64,6 +64,11 @@ public class PgpDecryptionService {
|
||||||
this.pendingNotifications.removeAll(discards);
|
this.pendingNotifications.removeAll(discards);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public synchronized void discard(Message message) {
|
||||||
|
this.messages.remove(message);
|
||||||
|
this.pendingNotifications.remove(message);
|
||||||
|
}
|
||||||
|
|
||||||
protected synchronized void decryptNext() {
|
protected synchronized void decryptNext() {
|
||||||
if (pendingIntent == null
|
if (pendingIntent == null
|
||||||
&& getOpenPgpApi() != null
|
&& getOpenPgpApi() != null
|
||||||
|
|
|
@ -483,6 +483,7 @@ public class MessageParser extends AbstractParser implements OnMessagePacketRece
|
||||||
sendMessageReceipts(account, packet);
|
sendMessageReceipts(account, packet);
|
||||||
}
|
}
|
||||||
if (replacedMessage.getEncryption() == Message.ENCRYPTION_PGP) {
|
if (replacedMessage.getEncryption() == Message.ENCRYPTION_PGP) {
|
||||||
|
conversation.getAccount().getPgpDecryptionService().discard(replacedMessage);
|
||||||
conversation.getAccount().getPgpDecryptionService().decrypt(replacedMessage, false);
|
conversation.getAccount().getPgpDecryptionService().decrypt(replacedMessage, false);
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
|
|
Loading…
Reference in New Issue