@@ -105,10 +105,7 @@ public void scheduledPolicyRefresh() {
105105
106106 @ Override
107107 public ChannelProcessorInfo processorInfo () {
108- String policyCounts =
109- cachedPolicies .entrySet ().stream ()
110- .map (e -> e .getKey () + "=" + e .getValue ())
111- .collect (Collectors .joining (", " ));
108+ String cachedPoliciesStringValue = cachedPoliciesRepresentation (cachedPolicies );
112109 return new ChannelProcessorInfo (
113110 "AAChannelProcessor" ,
114111 aaEnabled ,
@@ -128,7 +125,7 @@ public ChannelProcessorInfo processorInfo() {
128125 "lastPolicyRefresh" ,
129126 lastPolicyRefresh == null ? "never" : lastPolicyRefresh .toString (),
130127 "cachedPoliciesPerArchiver" ,
131- policyCounts .isEmpty () ? "none" : policyCounts ));
128+ cachedPoliciesStringValue .isEmpty () ? "none" : cachedPoliciesStringValue ));
132129 }
133130
134131 /**
@@ -393,6 +390,12 @@ private Map<String, ArchiverInfo> getArchiversInfoFromCache() {
393390 e .getKey (), e .getValue (), snapshot .get (e .getKey ()).policies ())));
394391 }
395392
393+ private static String cachedPoliciesRepresentation (Map <String , ArchiverPolicies > policies ) {
394+ return policies .entrySet ().stream ()
395+ .map (e -> e .getKey () + "=" + e .getValue ())
396+ .collect (Collectors .joining (", " ));
397+ }
398+
396399 private void refreshPolicies () {
397400 if (aaURLs .isEmpty ()) {
398401 logger .log (Level .FINE , "No archivers configured; skipping policy cache refresh." );
@@ -426,11 +429,7 @@ private void refreshPolicies() {
426429 if (!changed .isEmpty ()) {
427430 cachedPolicies = Collections .unmodifiableMap (updated );
428431 logger .log (
429- Level .INFO ,
430- "AA policy cache updated: {0}" ,
431- cachedPolicies .entrySet ().stream ()
432- .map (e -> e .getKey () + "=" + e .getValue ())
433- .collect (Collectors .joining (", " )));
432+ Level .INFO , "AA policy cache updated: {0}" , cachedPoliciesRepresentation (cachedPolicies ));
434433 } else {
435434 logger .log (Level .FINE , "AA policy cache unchanged after refresh." );
436435 }
0 commit comments