Format PulsarConnectionFactory.java

pulsar-jms/src/main/java/com/datastax/oss/pulsar/jms/PulsarConnectionFactory.java

@@ -1379,23 +1379,24 @@ public int compare(Message o1, Message o2) {
     }
   }
 
-  private static void setReceiverQueueSizeForJMSPriority(ConsumerBase consumerBase) throws Exception {
+  private static void setReceiverQueueSizeForJMSPriority(ConsumerBase consumerBase)
+      throws Exception {
     Field consumersField = MultiTopicsConsumerImpl.class.getDeclaredField("consumers");
 
     consumersField.setAccessible(true);
 
     ConcurrentHashMap<String, ConsumerImpl<?>> consumers =
-            (ConcurrentHashMap) consumersField.get(consumerBase);
+        (ConcurrentHashMap) consumersField.get(consumerBase);
     Method setCurrentReceiverQueueSizeMethod =
-            ConsumerImpl.class.getDeclaredMethod("setCurrentReceiverQueueSize", int.class);
+        ConsumerImpl.class.getDeclaredMethod("setCurrentReceiverQueueSize", int.class);
     setCurrentReceiverQueueSizeMethod.setAccessible(true);
 
     // set the queue size for each consumer based on the partition index
     // we set a higher number to the consumers for the higher priority partitions
     // this way the backlog is drained more quickly for the higher priority partitions
     int numConsumers = consumers.size();
     int sumPriorities =
-            (numConsumers * (numConsumers + 1)) / 2; // 1 + 2 + 3 + 4 + 5 + 6 + 7 + 8 + 9 + 10
+        (numConsumers * (numConsumers + 1)) / 2; // 1 + 2 + 3 + 4 + 5 + 6 + 7 + 8 + 9 + 10
     int receiverQueueSize = consumerBase.getCurrentReceiverQueueSize();
 
     for (ConsumerImpl<?> consumer : consumers.values()) {