logger.info("Starting server on " + address.toString());
final var server = HttpServer.create(address, 0);
- server.setExecutor(Executors.newFixedThreadPool(10));
+ server.setExecutor(Executors.newCachedThreadPool());
server.createContext("/api/v1/rpc", this::handleRpcEndpoint);
server.createContext("/api/v1/events", this::handleEventsEndpoint);
}
private List<Manager> getManagerFromQuery(final Map<String, String> query) {
- List<Manager> managers;
if (m != null) {
- managers = List.of(m);
- } else {
+ return List.of(m);
+ }
+ if (c != null) {
final var account = query.get("account");
if (account == null || account.isEmpty()) {
- managers = c.getManagers();
+ return c.getManagers();
} else {
final var manager = c.getManager(account);
if (manager == null) {
return null;
}
- managers = List.of(manager);
+ return List.of(manager);
}
}
- return managers;
+ return List.of();
}
private List<Pair<Manager, Manager.ReceiveMessageHandler>> subscribeReceiveHandlers(