Merge branch 'nats-v2-web' of github.com:/sonus21/rqueue into nats-v2-web

Author: sonus21

rqueue-core/src/test/java/com/github/sonus21/rqueue/listener/RqueueMiddlewareTest.java

@@ -401,12 +401,14 @@ void middlewareRunsWhenMessageConverterThrows() {
     // built above with the working converter, so only the inbound conversion fails.
     MessageConverter throwingConverter = new MessageConverter() {
       @Override
-      public Object fromMessage(org.springframework.messaging.Message<?> message, Class<?> targetClass) {
+      public Object fromMessage(
+          org.springframework.messaging.Message<?> message, Class<?> targetClass) {
         throw new IllegalStateException("boom: converter failed");
       }
 
       @Override
-      public org.springframework.messaging.Message<?> toMessage(Object payload, org.springframework.messaging.MessageHeaders headers) {
+      public org.springframework.messaging.Message<?> toMessage(
+          Object payload, org.springframework.messaging.MessageHeaders headers) {
         return null;
       }
     };

rqueue-web/src/test/java/com/github/sonus21/rqueue/web/service/RqueueQDetailServiceBrokerRoutingTest.java

@@ -193,7 +193,8 @@ void peekRoutesThroughBrokerForReadyList() {
     DataViewResponse response = service.getExplorePageData(
         queueConfig.getName(), queueConfig.getQueueName(), DataType.LIST, null, 0, 10);
 
-    verify(messageBroker, atLeastOnce()).peek(any(QueueDetail.class), nullable(String.class), anyLong(), anyLong());
+    verify(messageBroker, atLeastOnce())
+        .peek(any(QueueDetail.class), nullable(String.class), anyLong(), anyLong());
     assertTrue(response.getRows() == null || response.getRows().isEmpty());
   }