Fix potential NullPointerException in RateLimiter
This commit is contained in:
		
							parent
							
								
									cd6b2512e1
								
							
						
					
					
						commit
						0e6cfb460d
					
				| 
						 | 
					@ -132,8 +132,10 @@ public class RateLimiter {
 | 
				
			||||||
      logger.warn("Deserialization error", e);
 | 
					      logger.warn("Deserialization error", e);
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    if (secondaryCacheCluster != null) {
 | 
				
			||||||
      try {
 | 
					      try {
 | 
				
			||||||
      final String serialized = secondaryCacheCluster.withCluster(connection -> connection.sync().get(getBucketName(key)));
 | 
					        final String serialized = secondaryCacheCluster
 | 
				
			||||||
 | 
					            .withCluster(connection -> connection.sync().get(getBucketName(key)));
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        if (serialized != null) {
 | 
					        if (serialized != null) {
 | 
				
			||||||
          return LeakyBucket.fromSerialized(mapper, serialized);
 | 
					          return LeakyBucket.fromSerialized(mapper, serialized);
 | 
				
			||||||
| 
						 | 
					@ -141,6 +143,7 @@ public class RateLimiter {
 | 
				
			||||||
      } catch (IOException e) {
 | 
					      } catch (IOException e) {
 | 
				
			||||||
        logger.warn("Deserialization error", e);
 | 
					        logger.warn("Deserialization error", e);
 | 
				
			||||||
      }
 | 
					      }
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    return new LeakyBucket(bucketSize, leakRatePerMillis);
 | 
					    return new LeakyBucket(bucketSize, leakRatePerMillis);
 | 
				
			||||||
  }
 | 
					  }
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue