Skip to content

Commit 7948960

Browse files
committed
fix: fix hanging mongo connections
1 parent 40c8046 commit 7948960

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/application/ApplicationApiServiceImpl.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
import org.springframework.stereotype.Service;
5050
import reactor.core.publisher.Flux;
5151
import reactor.core.publisher.Mono;
52+
import reactor.core.scheduler.Schedulers;
5253

5354
import java.time.Duration;
5455
import java.time.Instant;
@@ -480,6 +481,7 @@ public Mono<ResourcePermission> checkPermissionWithReadableErrorMsg(String appli
480481
public Mono<ResourcePermission> checkApplicationPermissionWithReadableErrorMsg(String applicationId, ResourceAction action, ApplicationRequestType requestType) {
481482
return sessionUserService.getVisitorId()
482483
.flatMap(visitorId -> resourcePermissionService.checkUserPermissionStatusOnApplication(visitorId, applicationId, action, requestType))
484+
.publishOn(Schedulers.boundedElastic())
483485
.flatMap(permissionStatus -> {
484486
if (!permissionStatus.hasPermission()) {
485487

@@ -488,7 +490,7 @@ public Mono<ResourcePermission> checkApplicationPermissionWithReadableErrorMsg(S
488490
orgId = applicationService.findById(applicationId)
489491
.map(Application::getOrganizationId)
490492
.onErrorReturn("")
491-
.block(Duration.ofSeconds(2));
493+
.block(Duration.ofSeconds(5));
492494
} catch(Throwable cause) {
493495
log.warn("Couldn't get orgId! - {}", cause.getMessage());
494496
}

0 commit comments

Comments
 (0)