Skip to content

Commit 105d899

Browse files
committed
feat: add api rate limiter
1 parent 956122e commit 105d899

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

src/main/java/tech/wetech/flexmodel/domain/model/settings/SettingsChanged.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,5 +11,5 @@
1111
@AllArgsConstructor
1212
@ToString
1313
public class SettingsChanged {
14-
private Settings settings;
14+
private Settings message;
1515
}

src/main/java/tech/wetech/flexmodel/infrastructrue/SettingsEventConsumer.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import io.quarkus.vertx.ConsumeEvent;
44
import jakarta.enterprise.context.ApplicationScoped;
5+
import lombok.extern.slf4j.Slf4j;
56
import tech.wetech.flexmodel.domain.model.api.ApiRateLimiterHolder;
67
import tech.wetech.flexmodel.domain.model.settings.SettingsChanged;
78

@@ -11,13 +12,14 @@
1112
/**
1213
* @author cjbi
1314
*/
15+
@Slf4j
1416
@ApplicationScoped
1517
public class SettingsEventConsumer {
1618

1719

1820
@ConsumeEvent("settings-changed") // 监听特定地址的事件
1921
public void consume(SettingsChanged event) {
20-
System.out.println("Received message: " + event.getSettings());
22+
log.info("Received message: {}", event.getMessage());
2123
// 处理事件
2224
List<String> invalidKeys = new ArrayList<>();
2325
ApiRateLimiterHolder.getMap().forEach((k, v) -> {

0 commit comments

Comments
 (0)