checkstyle

allegro · Aug 10, 2023 · b3aba69 · b3aba69
1 parent 4b02f81
commit b3aba69
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/...rs/src/main/java/pl/allegro/tech/hermes/consumers/config/ConsumerSenderConfiguration.java b/...rs/src/main/java/pl/allegro/tech/hermes/consumers/config/ConsumerSenderConfiguration.java
@@ -53,11 +53,11 @@
 import pl.allegro.tech.hermes.consumers.consumer.sender.timeout.FutureAsyncTimeout;
 import pl.allegro.tech.hermes.consumers.consumer.trace.MetadataAppender;
 
-import javax.jms.Message;
 import java.io.IOException;
 import java.util.List;
 import java.util.Optional;
 import java.util.concurrent.ScheduledExecutorService;
+import javax.jms.Message;
 
 @Configuration
 @EnableConfigurationProperties({
@@ -261,7 +261,7 @@ public EndpointAddressResolver interpolatingEndpointAddressResolver(UriInterpola
 
     @Bean
     public FutureAsyncTimeout futureAsyncTimeoutFactory(InstrumentedExecutorServiceFactory executorFactory,
-                                                                              SenderAsyncTimeoutProperties senderAsyncTimeoutProperties) {
+                                                        SenderAsyncTimeoutProperties senderAsyncTimeoutProperties) {
         ScheduledExecutorService timeoutExecutorService = executorFactory.getScheduledExecutorService(
                 "async-timeout",
                 senderAsyncTimeoutProperties.getThreadPoolSize(),

diff --git a/...s/src/main/java/pl/allegro/tech/hermes/consumers/consumer/batch/MessageBatchReceiver.java b/...s/src/main/java/pl/allegro/tech/hermes/consumers/consumer/batch/MessageBatchReceiver.java
@@ -16,13 +16,13 @@
 import pl.allegro.tech.hermes.tracker.consumers.MessageMetadata;
 import pl.allegro.tech.hermes.tracker.consumers.Trackers;
 
-import javax.annotation.concurrent.NotThreadSafe;
 import java.util.ArrayDeque;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
 import java.util.Queue;
 import java.util.Set;
+import javax.annotation.concurrent.NotThreadSafe;
 
 import static com.google.common.base.Preconditions.checkArgument;
 import static pl.allegro.tech.hermes.consumers.consumer.Message.message;

diff --git a/...src/main/java/pl/allegro/tech/hermes/consumers/consumer/result/DefaultSuccessHandler.java b/...src/main/java/pl/allegro/tech/hermes/consumers/consumer/result/DefaultSuccessHandler.java
@@ -35,6 +35,7 @@ private void markSuccess(Message message, SubscriptionName subscription, Message
         metrics.subscriptions().successes(subscription).increment();
         metrics.subscriptions().throughputInBytes(subscription).increment(message.getSize());
         metrics.subscriptions().httpAnswerCounter(subscription, result.getStatusCode()).increment();
-        metrics.subscriptions().inflightTimeInMillisHistogram(subscription).record(System.currentTimeMillis() - message.getReadingTimestamp());
+        metrics.subscriptions().inflightTimeInMillisHistogram(subscription)
+                .record(System.currentTimeMillis() - message.getReadingTimestamp());
     }
 }