cqrenet/mxids
3
0
Fork 0
Code Pull Requests 10 Actions Releases Activity

Cosmetic refactoring

Browse Source
This commit is contained in:
Maxime Dor
2017-09-16 13:46:15 +02:00
parent 37b0f29184
commit f97aa8cbef
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/groovy/io/kamax/mxisd/invitation/InvitationManager.java
View File

@@ -235,12 +235,14 @@ public class InvitationManager {
} }
public void lookupMappingsForInvites() { public void lookupMappingsForInvites() {
if (!invitations.isEmpty()) {
log.info("Checking for existing mapping for pending invites"); log.info("Checking for existing mapping for pending invites");
for (IThreePidInviteReply reply : invitations.values()) { for (IThreePidInviteReply reply : invitations.values()) {
log.info("Processing invite {}", getIdForLog(reply)); log.info("Processing invite {}", getIdForLog(reply));
ForkJoinPool.commonPool().submit(new MappingChecker(reply)); ForkJoinPool.commonPool().submit(new MappingChecker(reply));
} }
} }
}
public void publishMappingIfInvited(ThreePidMapping threePid) { public void publishMappingIfInvited(ThreePidMapping threePid) {
log.info("Looking up possible pending invites for {}:{}", threePid.getMedium(), threePid.getValue()); log.info("Looking up possible pending invites for {}:{}", threePid.getMedium(), threePid.getValue());