this.maxWriteQueueSize = maxQueueSize;
this.evcacheMemcachedClient = new EVCacheMemcachedClient(connectionFactory, memcachedNodesInZone, readTimeout, appName, zone, id, serverGroup);
this.connectionObserver = new EVCacheConnectionObserver(appName, serverGroup, id);
this.evcacheMemcachedClient.addObserver(connectionObserver);
}
<BUG>private Collection<String> validateReadQueueSize(Collection<String> canonicalKeys) {
</BUG>
if (evcacheMemcachedClient.getNodeLocator() == null) return canonicalKeys;
final Collection<String> retKeys = new ArrayList<>(canonicalKeys.size());
for (String key : canonicalKeys) {

this.maxWriteQueueSize = maxQueueSize;
this.evcacheMemcachedClient = new EVCacheMemcachedClient(connectionFactory, memcachedNodesInZone, readTimeout, appName, zone, id, serverGroup);
this.connectionObserver = new EVCacheConnectionObserver(appName, serverGroup, id);
this.evcacheMemcachedClient.addObserver(connectionObserver);
}
private Collection<String> validateReadQueueSize(Collection<String> canonicalKeys) throws EVCacheException {
if (evcacheMemcachedClient.getNodeLocator() == null) return canonicalKeys;
final Collection<String> retKeys = new ArrayList<>(canonicalKeys.size());
for (String key : canonicalKeys) {
