1.add subscribe for access stat channel to really send data

2.set stat.open true to open push access stat data
This commit is contained in:
zhongjie
2020-11-24 18:42:35 +08:00
parent b0dfb36fb8
commit 9114a87624
2 changed files with 6 additions and 2 deletions

View File

@@ -112,7 +112,7 @@ public class StatPluginFilter extends PluginFilter {
b.append(Constants.Symbol.RIGHT_BRACE);
if (StringUtils.isBlank(fizzAccessStatTopic)) {
rt.convertAndSend(fizzAccessStatChannel, b.toString());
rt.convertAndSend(fizzAccessStatChannel, b.toString()).subscribe();
} else {
log.info(b.toString(), LogService.HANDLE_STGY, LogService.toKF(fizzAccessStatTopic));
}

View File

@@ -78,4 +78,8 @@ aggr-webclient:
fizz-web-client:
timeout: 20000
log:
headers: COOKIE,FIZZ-APPID,FIZZ-SECRETKEY,FIZZ-SIGN,FIZZ-TS,FIZZ-RSV
headers: COOKIE,FIZZ-APPID,FIZZ-SECRETKEY,FIZZ-SIGN,FIZZ-TS,FIZZ-RSV
stat:
# switch for push access stat data
open: true