Improve message resending
This commit is contained in:
parent
8a2edbe661
commit
c01d09d519
|
@ -46,6 +46,7 @@ public class MessageProcessor : StreamInteractionModule, Object {
|
||||||
stream_interactor.account_added.connect(on_account_added);
|
stream_interactor.account_added.connect(on_account_added);
|
||||||
|
|
||||||
stream_interactor.stream_negotiated.connect(send_unsent_chat_messages);
|
stream_interactor.stream_negotiated.connect(send_unsent_chat_messages);
|
||||||
|
stream_interactor.stream_resumed.connect(send_unsent_chat_messages);
|
||||||
|
|
||||||
stream_interactor.connection_manager.stream_opened.connect((account, stream) => {
|
stream_interactor.connection_manager.stream_opened.connect((account, stream) => {
|
||||||
debug("MAM: [%s] Reset catchup_id", account.bare_jid.to_string());
|
debug("MAM: [%s] Reset catchup_id", account.bare_jid.to_string());
|
||||||
|
@ -662,7 +663,7 @@ public class MessageProcessor : StreamInteractionModule, Object {
|
||||||
|
|
||||||
if (stream != stream_interactor.get_stream(conversation.account)) {
|
if (stream != stream_interactor.get_stream(conversation.account)) {
|
||||||
Timeout.add_seconds(3, () => {
|
Timeout.add_seconds(3, () => {
|
||||||
send_xmpp_message(message, conversation, true);
|
send_unsent_chat_messages(conversation.account);
|
||||||
return false;
|
return false;
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue