Commit e2760e4f authored by Florian Fittkau's avatar Florian Fittkau

minor

parent 6793417c
......@@ -52,7 +52,7 @@ public class MonitoringController {
TraceRegistry.init(configuration);
final ExecutorService exec = Executors.newCachedThreadPool();
final ExecutorService exec = Executors.newSingleThreadExecutor();
final Disruptor<ByteBufferEvent> disruptor = new Disruptor<ByteBufferEvent>(
ByteBufferEvent.EVENT_FACTORY, Constants.MONITORING_CONTROLLER_DISRUPTOR_SIZE,
exec, ProducerType.MULTI, new BlockingWaitStrategy());
......@@ -90,9 +90,9 @@ public class MonitoringController {
configuration.getIntProperty(ConfigurationFactory.LOAD_BALANCER_PORT, 9999),
configuration.getIntProperty(ConfigurationFactory.LOAD_BALANCER_WAIT_TIME,
20000),
configuration
configuration
.getStringProperty(ConfigurationFactory.LOAD_BALANCER_SCALING_GROUP),
tcpWriter);
tcpWriter);
} else {
try {
tcpWriter.connect();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment