diff --git a/src/main/java/com/degressly/proxy/core/service/impl/DefaultReplayHandlerImpl.java b/src/main/java/com/degressly/proxy/core/service/impl/DefaultReplayHandlerImpl.java index c23fcc6..9b96a56 100644 --- a/src/main/java/com/degressly/proxy/core/service/impl/DefaultReplayHandlerImpl.java +++ b/src/main/java/com/degressly/proxy/core/service/impl/DefaultReplayHandlerImpl.java @@ -68,8 +68,7 @@ private void performOneConcurrentOutgoingRequest(DegresslyRequest degresslyReque log.error("Error while executing incoming request: ", e); } } - previousIncomingRequestFuture = incomingExecutorService - .submit(() -> handleIncomingRequest(degresslyRequest)); + previousIncomingRequestFuture = incomingExecutorService.submit(() -> handleIncomingRequest(degresslyRequest)); } private void handleIncomingRequest(DegresslyRequest degresslyRequest) {