spotless changes

lensesio · May 22, 2024 · 634953a · 634953a
1 parent c506b2a
commit 634953a
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/...va/io/lenses/streamreactor/connect/azure/servicebus/source/AzureServiceBusSourceTask.java b/...va/io/lenses/streamreactor/connect/azure/servicebus/source/AzureServiceBusSourceTask.java
@@ -51,16 +51,16 @@ public String version() {
 
   @Override
   public void start(Map<String, String> props) {
-    int recordsQueueDefaultSize = new AzureServiceBusSourceConfig(props)
-        .getInt(AzureServiceBusConfigConstants.TASK_RECORDS_QUEUE_SIZE);
+    int recordsQueueDefaultSize =
+        new AzureServiceBusSourceConfig(props)
+            .getInt(AzureServiceBusConfigConstants.TASK_RECORDS_QUEUE_SIZE);
     String connectionString = props.get(AzureServiceBusConfigConstants.CONNECTION_STRING);
     List<Kcql> kcqls =
         KcqlConfigBusMapper.mapKcqlsFromConfig(props.get(AzureServiceBusConfigConstants.KCQL_CONFIG));
 
     OffsetStorageReader offsetStorageReader =
         ofNullable(this.context).flatMap(
             context -> ofNullable(context.offsetStorageReader())).orElseThrow();
-
 
     ArrayBlockingQueue<ServiceBusMessageHolder> recordsQueue =
         new ArrayBlockingQueue<>(recordsQueueDefaultSize);

diff --git a/...io/lenses/streamreactor/connect/azure/servicebus/source/ServiceBusReceiverFacadeTest.java b/...io/lenses/streamreactor/connect/azure/servicebus/source/ServiceBusReceiverFacadeTest.java
@@ -118,7 +118,6 @@ void completeShouldCallRecieverComplete() {
     verify(receiverAsyncClient).complete(mockedMessage);
   }
 
-
   private static Kcql mockKcql(Map<String, String> propertiesMap) {
     String inputBusName = "INPUT";
     Kcql kcql = mock(Kcql.class);

diff --git a/...ava/io/lenses/streamreactor/connect/azure/servicebus/source/TaskToReceiverBridgeTest.java b/...ava/io/lenses/streamreactor/connect/azure/servicebus/source/TaskToReceiverBridgeTest.java
@@ -128,7 +128,7 @@ void commitMessageInServiceBusShouldCallExecutorService() {
     verify(executorService).submit(any(Runnable.class));
   }
 
-  private ServiceBusReceiverFacade mockReceiver(String receiverId){
+  private ServiceBusReceiverFacade mockReceiver(String receiverId) {
     ServiceBusReceiverFacade receiverFacade = mock(ServiceBusReceiverFacade.class);
     when(receiverFacade.getReceiverId()).thenReturn(receiverId);
 

diff --git a/...t/java/io/lenses/streamreactor/connect/azure/servicebus/util/KcqlConfigBusMapperTest.java b/...t/java/io/lenses/streamreactor/connect/azure/servicebus/util/KcqlConfigBusMapperTest.java
@@ -56,8 +56,9 @@ void mapInputToOutputsFromConfigForMultipleKcqlStatementsShouldReturnMapOfInputT
       fullKcql.append(" ").append(createNecessaryPropertiesPart()).append(";");
     }
     //when
-    List<Kcql> kcqls = KcqlConfigBusMapper.mapKcqlsFromConfig(
-        fullKcql.toString());
+    List<Kcql> kcqls =
+        KcqlConfigBusMapper.mapKcqlsFromConfig(
+            fullKcql.toString());
 
     //then
     for (int i = 0; i < numberOfMappings; i++) {