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:
@@ -112,7 +112,7 @@ public class StatPluginFilter extends PluginFilter {
|
|||||||
b.append(Constants.Symbol.RIGHT_BRACE);
|
b.append(Constants.Symbol.RIGHT_BRACE);
|
||||||
|
|
||||||
if (StringUtils.isBlank(fizzAccessStatTopic)) {
|
if (StringUtils.isBlank(fizzAccessStatTopic)) {
|
||||||
rt.convertAndSend(fizzAccessStatChannel, b.toString());
|
rt.convertAndSend(fizzAccessStatChannel, b.toString()).subscribe();
|
||||||
} else {
|
} else {
|
||||||
log.info(b.toString(), LogService.HANDLE_STGY, LogService.toKF(fizzAccessStatTopic));
|
log.info(b.toString(), LogService.HANDLE_STGY, LogService.toKF(fizzAccessStatTopic));
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -78,4 +78,8 @@ aggr-webclient:
|
|||||||
fizz-web-client:
|
fizz-web-client:
|
||||||
timeout: 20000
|
timeout: 20000
|
||||||
log:
|
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
|
||||||
Reference in New Issue
Block a user