Update messaging-dump-cluster-database-CJOC.groovy (#242)

Editing the script as per @jtnord https://cloudbees.slack.com/archives/CBZDSFLF3/p1738941045501619?thread_ts=1738940068.263629&cid=CBZDSFLF3

Author: MCardenasBlanco

messaging-dump-cluster-database-CJOC.groovy

@@ -3,7 +3,6 @@
  * Dumps information related to the cluster messaging database.
  * Only to be executer on CJOC.
  */
-
 import java.io.PrintStream;
 import java.lang.reflect.Field;
 import java.lang.reflect.Method;
@@ -14,23 +13,18 @@ import java.util.Map.Entry;
 import java.util.Set;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.ConcurrentNavigableMap;
-
 import com.cloudbees.opscenter.context.Messaging;
 import com.cloudbees.opscenter.context.Messaging.OutboxEntry;
 import com.cloudbees.opscenter.server.messaging.Transport;
 import com.cloudbees.opscenter.server.model.ConnectedMaster;
-
 import hudson.ExtensionList;
 import hudson.model.AsyncPeriodicWork;
 import hudson.model.PeriodicWork;
 import hudson.remoting.Channel;
 import jenkins.model.Jenkins;
-
-
 Jenkins jenkins = Jenkins.getInstance();
 out.println("InstanceId: " + jenkins.getLegacyInstanceId());
 Transport transport = getTransport();
-
 try {
     for (ConnectedMaster m : jenkins.getAllItems(ConnectedMaster.class)) {
         String instanceId = m.getLegacyInstanceId();
@@ -43,25 +37,20 @@ try {
         } else {
             continue;
         }
-
         out.println("     capabilities: " + m.checkCapability(Messaging.class));
-
         Method method;
-
         try {
             out.println("     batchSource: " + transport.getBatchSource(channel));
         } catch (Exception e) {
             out.println("        Error batchSource: " + e.toString());
             out.println("     batchSource: " + Messaging.batchSource());
         }
-
         try {
             out.println("     batchSink: " + transport.getBatchSink(channel));
         } catch (Exception e) {
             out.println("        Error batchSink: " + e.toString());
             out.println("     batchSink: " + Messaging.batchSink());
         }
-
         try {
             out.println("     reliableMessageTransport: " + transport.getReliableMessageTransport(channel));
         } catch (Exception e) {
@@ -73,21 +62,16 @@ try {
     e.printStackTrace(out);
 }
 final ClassLoader oldContext = Thread.currentThread().getContextClassLoader();
-
 try {
     Thread.currentThread().setContextClassLoader(Jenkins.getInstance().getPluginManager().uberClassLoader);
-
     Map<ConnectedMaster, Map<Class<?>, Map<String, List<Object>>>> offlineBuffer;
-
     ConcurrentMap<String, Long> maxPull;
     ConcurrentMap<String, Long> minPush;
-    ConcurrentNavigableMap<String, Messaging.OutboxEntry<?>> outbox;
-
+    NavigableMap<String, Messaging.OutboxEntry<?>> outbox;
     maxPull = transport.maxPull;
     minPush = transport.minPush;
     outbox = transport.outbox
     offlineBuffer = transport.offlineBuffer
-
     try {
         out.println("maxPulls:");
         Set<Entry<String, Long>> entrySet = maxPull.entrySet();
@@ -98,7 +82,6 @@ try {
         out.println("Could not get maxPulls information");
         e.printStackTrace(out);
     }
-
     try {
         out.println("minPush:");
         Set<Entry<String, Long>> entrySet = minPush.entrySet();
@@ -109,11 +92,9 @@ try {
         out.println("Could not get minPush information");
         e.printStackTrace(out);
     }
-
     try {
         out.println("outbox:");
         Set<Entry<String, OutboxEntry<?>>> entrySet = outbox.entrySet();
-
         for (Entry<String, OutboxEntry<?>> entry : entrySet) {
             OutboxEntry<?> value = entry.getValue();
             out.println("  - " + entry.getKey() + "- source:" + value.getAddress() +
@@ -125,16 +106,13 @@ try {
         out.println("Could not get minPulls information");
         e.printStackTrace(out);
     }
-
     try {
         Set<Entry<ConnectedMaster, Map<Class<?>, Map<String, List<Object>>>>> entrySet = offlineBuffer.entrySet();
         out.println("offlineBuffer: " + offlineBuffer.size());
-
         for (Entry<ConnectedMaster, Map<Class<?>, Map<String, List<Object>>>> entry : entrySet) {
             Map<Class<?>, Map<String, List<Object>>> messagesMap = entry.getValue();
             ConnectedMaster key = entry.getKey();
             out.println("  " + key.getFullDisplayName() + "(" + key.getLegacyInstanceId() + ") - " + messagesMap.size());
-
             for (Entry<Class<?>, Map<String, List<Object>>> messages : messagesMap.entrySet()) {
                 Map<String, List<Object>> value = messages.getValue();
                 out.println("    " + messages.getKey() + ":" + value.size());
@@ -151,7 +129,6 @@ try {
 } finally {
     Thread.currentThread().setContextClassLoader(oldContext);
 }
-
 Transport getTransport() {
     ExtensionList<PeriodicWork> all = AsyncPeriodicWork.all();
     for (PeriodicWork periodicWork : all) {