private final ListeningExecutorService threadPool;
private final ConnectionSupplier connectionSupplier;
private final AtomicBoolean withCurrent = new AtomicBoolean();
private final ListeningExecutorService threadPool;
private final ConnectionSupplier connectionSupplier;
private final AtomicBoolean withCurrent = new AtomicBoolean();
public GetConfigCommandImpl(ExecutorService threadPool, ConnectionSupplier connectionSupplier) {
this.threadPool = MoreExecutors.listeningDecorator(threadPool);
public GetConfigCommandImpl(ExecutorService threadPool, ConnectionSupplier connectionSupplier) {
this.threadPool = MoreExecutors.listeningDecorator(threadPool);
private ConfigData executeDialog() throws IOException, ExecutionException, InterruptedException {
GetConfig getConfig = new GetConfig(new RandomIdentifierGenerator().generate());
getConfig.setWithCurrent(withCurrent.get());
private ConfigData executeDialog() throws IOException, ExecutionException, InterruptedException {
GetConfig getConfig = new GetConfig(new RandomIdentifierGenerator().generate());
getConfig.setWithCurrent(withCurrent.get());
try (GetConfigDialog getConfigDialog = new GetConfigDialog()) {
return getConfigDialog.send(getConfig).get();
}
try (GetConfigDialog getConfigDialog = new GetConfigDialog()) {
return getConfigDialog.send(getConfig).get();
}