iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update bucket4j version in spring-boot-libraries

Browse Source
This commit is contained in:
Ehsan Sasanianno 2022-11-19 17:11:59 +01:00
parent 032b8e2d64
commit bf057db224
3 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spring-boot-modules/spring-boot-libraries/pom.xml
View File

@ -226,8 +226,8 @@
<barcode4j.version>2.1</barcode4j.version> <barcode4j.version>2.1</barcode4j.version>
<qrgen.version>2.6.0</qrgen.version> <qrgen.version>2.6.0</qrgen.version>
<zxing.version>3.3.0</zxing.version> <zxing.version>3.3.0</zxing.version>
<bucket4j.version>4.10.0</bucket4j.version> <bucket4j.version>7.6.0</bucket4j.version>
<bucket4j-spring-boot-starter.version>0.2.0</bucket4j-spring-boot-starter.version> <bucket4j-spring-boot-starter.version>0.7.0</bucket4j-spring-boot-starter.version>
<caffeine.version>2.8.2</caffeine.version> <caffeine.version>2.8.2</caffeine.version>
</properties> </properties>

3
spring-boot-modules/spring-boot-libraries/src/main/java/com/baeldung/ratelimiting/bucket4japp/service/PricingPlanService.java
View File

@ -7,7 +7,6 @@ import org.springframework.stereotype.Service;
import io.github.bucket4j.Bandwidth; import io.github.bucket4j.Bandwidth;
import io.github.bucket4j.Bucket; import io.github.bucket4j.Bucket;
import io.github.bucket4j.Bucket4j;
@Service @Service
public class PricingPlanService { public class PricingPlanService {
@ -24,7 +23,7 @@ public class PricingPlanService {
} }
private Bucket bucket(Bandwidth limit) { private Bucket bucket(Bandwidth limit) {
return Bucket4j.builder() return Bucket.builder()
.addLimit(limit) .addLimit(limit)
.build(); .build();
} }

15
spring-boot-modules/spring-boot-libraries/src/test/java/com/baeldung/ratelimiting/bucket4japp/Bucket4jUsageUnitTest.java
View File

@ -1,7 +1,7 @@
package com.baeldung.ratelimiting.bucket4japp; package com.baeldung.ratelimiting.bucket4japp;
import static org.junit.Assert.assertFalse; import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.Assert.assertTrue; import static org.junit.jupiter.api.Assertions.assertTrue;
import java.time.Duration; import java.time.Duration;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
@ -13,7 +13,6 @@ import org.junit.jupiter.api.Test;
import io.github.bucket4j.Bandwidth; import io.github.bucket4j.Bandwidth;
import io.github.bucket4j.Bucket; import io.github.bucket4j.Bucket;
import io.github.bucket4j.Bucket4j;
import io.github.bucket4j.Refill; import io.github.bucket4j.Refill;
public class Bucket4jUsageUnitTest { public class Bucket4jUsageUnitTest {
@ -22,7 +21,7 @@ public class Bucket4jUsageUnitTest {
public void givenBucketLimit_whenExceedLimit_thenConsumeReturnsFalse() { public void givenBucketLimit_whenExceedLimit_thenConsumeReturnsFalse() {
Refill refill = Refill.intervally(10, Duration.ofMinutes(1)); Refill refill = Refill.intervally(10, Duration.ofMinutes(1));
Bandwidth limit = Bandwidth.classic(10, refill); Bandwidth limit = Bandwidth.classic(10, refill);
Bucket bucket = Bucket4j.builder() Bucket bucket = Bucket.builder()
.addLimit(limit) .addLimit(limit)
.build(); .build();
@ -34,7 +33,7 @@ public class Bucket4jUsageUnitTest {
@Test @Test
public void givenMultipletLimits_whenExceedSmallerLimit_thenConsumeReturnsFalse() { public void givenMultipletLimits_whenExceedSmallerLimit_thenConsumeReturnsFalse() {
Bucket bucket = Bucket4j.builder() Bucket bucket = Bucket.builder()
.addLimit(Bandwidth.classic(10, Refill.intervally(10, Duration.ofMinutes(1)))) .addLimit(Bandwidth.classic(10, Refill.intervally(10, Duration.ofMinutes(1))))
.addLimit(Bandwidth.classic(5, Refill.intervally(5, Duration.ofSeconds(20)))) .addLimit(Bandwidth.classic(5, Refill.intervally(5, Duration.ofSeconds(20))))
.build(); .build();
@ -49,7 +48,7 @@ public class Bucket4jUsageUnitTest {
public void givenBucketLimit_whenThrottleRequests_thenConsumeReturnsTrue() throws InterruptedException { public void givenBucketLimit_whenThrottleRequests_thenConsumeReturnsTrue() throws InterruptedException {
Refill refill = Refill.intervally(1, Duration.ofSeconds(2)); Refill refill = Refill.intervally(1, Duration.ofSeconds(2));
Bandwidth limit = Bandwidth.classic(1, refill); Bandwidth limit = Bandwidth.classic(1, refill);
Bucket bucket = Bucket4j.builder() Bucket bucket = Bucket.builder()
.addLimit(limit) .addLimit(limit)
.build(); .build();
@ -65,8 +64,8 @@ public class Bucket4jUsageUnitTest {
static class AssertTryConsume implements Runnable { static class AssertTryConsume implements Runnable {
private Bucket bucket; private final Bucket bucket;
private CountDownLatch latch; private final CountDownLatch latch;
AssertTryConsume(Bucket bucket, CountDownLatch latch) { AssertTryConsume(Bucket bucket, CountDownLatch latch) {
this.bucket = bucket; this.bucket = bucket;