@Override
public java.lang.AutoCloseable createInstance() {
LOG.info("SwitchConnectionProvider started.");
- SwitchConnectionProviderImpl switchConnectionProviderImpl = new SwitchConnectionProviderImpl();
+ final SwitchConnectionProviderImpl switchConnectionProviderImpl = new SwitchConnectionProviderImpl();
try {
- ConnectionConfiguration connConfiguration = createConnectionConfiguration();
+ final ConnectionConfiguration connConfiguration = createConnectionConfiguration();
switchConnectionProviderImpl.setConfiguration(connConfiguration);
- } catch (UnknownHostException e) {
+ } catch (final UnknownHostException e) {
throw new IllegalArgumentException(e.getMessage(), e);
}
return switchConnectionProviderImpl;
final long switchIdleTimeout = getSwitchIdleTimeout();
final Tls tlsConfig = getTls();
final Threads threads = getThreads();
+ final Boolean useBarrier = getUseBarrier();
final TransportProtocol transportProtocol = getTransportProtocol();
return new ConnectionConfiguration() {
}
};
}
+
+ @Override
+ public boolean useBarrier() {
+ return useBarrier;
+ }
};
}