Commit f60995be authored by Florian Fittkau's avatar Florian Fittkau

WiP

parent ea08affc
......@@ -11,9 +11,9 @@ import java.util.concurrent.Executors;
import org.aspectj.lang.Signature;
import com.lmax.disruptor.BlockingWaitStrategy;
import com.lmax.disruptor.EventHandler;
import com.lmax.disruptor.RingBuffer;
import com.lmax.disruptor.SleepingWaitStrategy;
import com.lmax.disruptor.dsl.Disruptor;
import com.lmax.disruptor.dsl.ProducerType;
......@@ -55,7 +55,7 @@ public class MonitoringController {
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());
exec, ProducerType.MULTI, new SleepingWaitStrategy(0));
final boolean androidMonitoring = configuration
.getBooleanProperty(ConfigurationFactory.ANDROID_MONITORING);
......@@ -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