add transport.connections_per_node prefix setting as well as the netty specific one
This commit is contained in:
parent
04b8245d96
commit
671db81992
|
@ -183,9 +183,9 @@ public class NettyTransport extends AbstractLifecycleComponent<Transport> implem
|
|||
this.reuseAddress = componentSettings.getAsBoolean("reuse_address", settings.getAsBoolean(TCP_REUSE_ADDRESS, NetworkUtils.defaultReuseAddress()));
|
||||
this.tcpSendBufferSize = componentSettings.getAsBytesSize("tcp_send_buffer_size", settings.getAsBytesSize(TCP_SEND_BUFFER_SIZE, TCP_DEFAULT_SEND_BUFFER_SIZE));
|
||||
this.tcpReceiveBufferSize = componentSettings.getAsBytesSize("tcp_receive_buffer_size", settings.getAsBytesSize(TCP_RECEIVE_BUFFER_SIZE, TCP_DEFAULT_RECEIVE_BUFFER_SIZE));
|
||||
this.connectionsPerNodeLow = componentSettings.getAsInt("connections_per_node.low", 2);
|
||||
this.connectionsPerNodeMed = componentSettings.getAsInt("connections_per_node.med", 7);
|
||||
this.connectionsPerNodeHigh = componentSettings.getAsInt("connections_per_node.high", 1);
|
||||
this.connectionsPerNodeLow = componentSettings.getAsInt("connections_per_node.low", settings.getAsInt("transport.connections_per_node.low", 2));
|
||||
this.connectionsPerNodeMed = componentSettings.getAsInt("connections_per_node.med", settings.getAsInt("transport.connections_per_node.med", 7));
|
||||
this.connectionsPerNodeHigh = componentSettings.getAsInt("connections_per_node.high", settings.getAsInt("transport.connections_per_node.high", 1));
|
||||
}
|
||||
|
||||
public Settings settings() {
|
||||
|
|
Loading…
Reference in New Issue