@@ -93,16 +93,16 @@ public NettyMemcachedServerTransport(Settings settings, RestController restContr
93
93
this .restController = restController ;
94
94
this .networkService = networkService ;
95
95
96
- this .workerCount = componentSettings .getAsInt ("worker_count" , Runtime .getRuntime ().availableProcessors () * 2 );
97
- this .blockingServer = componentSettings .getAsBoolean ("memcached.blocking_server" , settings .getAsBoolean (TCP_BLOCKING_SERVER , settings .getAsBoolean (TCP_BLOCKING , false )));
98
- this .port = componentSettings .get ("port" , settings .get ("memcached.port" , "11211-11311" ));
99
- this .bindHost = componentSettings .get ("bind_host" );
100
- this .publishHost = componentSettings .get ("publish_host" );
101
- this .tcpNoDelay = componentSettings .getAsBoolean ("tcp_no_delay" , settings .getAsBoolean (TCP_NO_DELAY , true ));
102
- this .tcpKeepAlive = componentSettings .getAsBoolean ("tcp_keep_alive" , settings .getAsBoolean (TCP_KEEP_ALIVE , true ));
103
- this .reuseAddress = componentSettings .getAsBoolean ("reuse_address" , settings .getAsBoolean (TCP_REUSE_ADDRESS , NetworkUtils .defaultReuseAddress ()));
104
- this .tcpSendBufferSize = componentSettings .getAsBytesSize ("tcp_send_buffer_size" , settings .getAsBytesSize (TCP_SEND_BUFFER_SIZE , TCP_DEFAULT_SEND_BUFFER_SIZE ));
105
- this .tcpReceiveBufferSize = componentSettings .getAsBytesSize ("tcp_receive_buffer_size" , settings .getAsBytesSize (TCP_RECEIVE_BUFFER_SIZE , TCP_DEFAULT_RECEIVE_BUFFER_SIZE ));
96
+ this .workerCount = settings .getAsInt ("memcached.netty. worker_count" , Runtime .getRuntime ().availableProcessors () * 2 );
97
+ this .blockingServer = settings .getAsBoolean ("memcached.netty. memcached.blocking_server" , settings .getAsBoolean (TCP_BLOCKING_SERVER , settings .getAsBoolean (TCP_BLOCKING , false )));
98
+ this .port = settings .get ("memcached.netty. port" , settings .get ("memcached.port" , "11211-11311" ));
99
+ this .bindHost = settings .get ("memcached.netty. bind_host" );
100
+ this .publishHost = settings .get ("memcached.netty. publish_host" );
101
+ this .tcpNoDelay = settings .getAsBoolean ("memcached.netty. tcp_no_delay" , settings .getAsBoolean (TCP_NO_DELAY , true ));
102
+ this .tcpKeepAlive = settings .getAsBoolean ("memcached.netty. tcp_keep_alive" , settings .getAsBoolean (TCP_KEEP_ALIVE , true ));
103
+ this .reuseAddress = settings .getAsBoolean ("memcached.netty. reuse_address" , settings .getAsBoolean (TCP_REUSE_ADDRESS , NetworkUtils .defaultReuseAddress ()));
104
+ this .tcpSendBufferSize = settings .getAsBytesSize ("memcached.netty. tcp_send_buffer_size" , settings .getAsBytesSize (TCP_SEND_BUFFER_SIZE , TCP_DEFAULT_SEND_BUFFER_SIZE ));
105
+ this .tcpReceiveBufferSize = settings .getAsBytesSize ("memcached.netty. tcp_receive_buffer_size" , settings .getAsBytesSize (TCP_RECEIVE_BUFFER_SIZE , TCP_DEFAULT_RECEIVE_BUFFER_SIZE ));
106
106
}
107
107
108
108
@ Override
0 commit comments