dapr · artur-ciocanu · Jun 12, 2025 · Apr 29, 2025 · Apr 29, 2025 · May 5, 2025
@@ -112,6 +112,7 @@
         <module name="ModifierOrder"/>
         <module name="EmptyLineSeparator">
             <property name="allowNoEmptyLineBetweenFields" value="true"/>
+            <property name="allowMultipleEmptyLines" value="false"/>
         </module>
         <module name="SeparatorWrap">
             <property name="id" value="SeparatorWrapDot"/>
@@ -287,4 +288,5 @@
         <module name="SuppressWarningsHolder"/>
     </module>
     <module name="SuppressWarningsFilter"/>
+    <module name="NewlineAtEndOfFile"/>
 </module>
@@ -23,7 +23,6 @@ public class DaprClientProperties {
   private Integer httpPort;
   private Integer grpcPort;
 
-
   /**
    * Constructs a {@link DaprClientProperties}.
    */

@@ -15,7 +15,6 @@
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
-
 @ConfigurationProperties(prefix = DaprPubSubProperties.CONFIG_PREFIX)
 public class DaprPubSubProperties {
 

@@ -76,7 +76,6 @@ public MySQLDaprKeyValueAdapter(DaprClient daprClient, ObjectMapper mapper, Stri
     this.bindingName = bindingName;
   }
 
-
   @Override
   public <T> Iterable<T> getAllOf(String keyspace, Class<T> type) {
     Assert.hasText(keyspace, "Keyspace must not be empty");

@@ -18,7 +18,6 @@ public DaprPredicate(PropertyPath path, Object expected) {
     this(path, expected, (valueToCompare) -> ObjectUtils.nullSafeEquals(valueToCompare, expected));
   }
 
-
   /**
    * Creates a new {@link DaprPredicate}.
    *

@@ -192,7 +192,6 @@ public SendMessageBuilder<T> withTopic(String topic) {
       return this;
     }
 
-
     @Override
     public void send() {
       template.doSend(topic, message);
@@ -202,7 +201,5 @@ public void send() {
     public Mono<Void> sendAsync() {
       return template.doSendAsync(topic, message);
     }
-
   }
-
 }
@@ -58,7 +58,6 @@ public Map<String, String> properties() {
     return carrier.properties();
   }
 
-
   /**
    * The name of the bean sending the message (typically a {@code DaprMessagingTemplate}).
    * @return the name of the bean sending the message
@@ -75,7 +74,6 @@ public String getDestination() {
     return this.destination;
   }
 
-
   /**
    * Acts as a carrier for a Dapr message and records the propagated properties for
    * later access by the Dapr.

@@ -1,6 +1,5 @@
 package io.dapr.spring.workflows.config;
 
-
 import org.springframework.context.annotation.Import;
 
 import java.lang.annotation.Retention;

@@ -13,6 +13,7 @@
 
 package io.dapr.examples.workflows.childworkflow;
 
+import io.dapr.durabletask.interruption.OrchestratorBlockedException;
 import io.dapr.workflows.Workflow;
 import io.dapr.workflows.WorkflowStub;
 import io.dapr.workflows.WorkflowTaskOptions;

@@ -123,7 +123,6 @@ public static ActorId createRandom() {
     return new ActorId(id.toString());
   }
 
-
   /**
    * Compares if two actors have the same content.
    *

@@ -130,7 +130,6 @@ public void close() {
     }
   }
 
-
   /**
    * Build an instance of the Client based on the provided setup.
    *

@@ -13,7 +13,6 @@
 
 package io.dapr.springboot;
 
-
 import io.dapr.actors.runtime.ActorRuntime;
 import io.dapr.serializer.DefaultObjectSerializer;
 import org.springframework.http.MediaType;
@@ -124,5 +123,4 @@ public Mono<Void> invokeActorReminder(@PathVariable("type") String type,
                                         @RequestBody(required = false) byte[] body) {
     return ActorRuntime.getInstance().invokeReminder(type, id, reminder, body);
   }
-
 }
@@ -123,7 +123,6 @@ class DaprTopicSubscription {
     this(pubsubName, topic, route, "", routes, metadata, bulkSubscribe);
   }
 
-
   /**
    * Create a subscription topic.
    *

@@ -48,7 +48,6 @@ public String getName() {
     return name;
   }
 
-
   @Override
   public TaskActivity create() {
     return ctx -> {

@@ -94,4 +94,4 @@ private void shutDownWorkerPool() {
       Thread.currentThread().interrupt();
     }
   }
-}
+}
@@ -655,7 +655,6 @@ public Mono<UnlockResponseStatus> unlock(String storeName, String resourceId, St
     return this.unlock(request);
   }
 
-
   private List<String> filterEmptyKeys(String... keys) {
     return Arrays.stream(keys)
         .filter(key -> !key.trim().isEmpty())

@@ -32,7 +32,6 @@ class GrpcChannelFacade implements Closeable {
    */
   private final ManagedChannel channel;
 
-
   /**
    * Default access level constructor, in order to create an instance of this class use io.dapr.client.DaprClientBuilder
    *

@@ -81,7 +81,6 @@ public T getEvent() {
     return event;
   }
 
-
   public String getContentType() {
     return contentType;
   }

@@ -20,4 +20,4 @@ public enum BulkSubscribeAppResponseStatus {
   SUCCESS,
   RETRY,
   DROP
-}
+}
@@ -55,4 +55,4 @@ public String getTopic() {
   public Map<String, String> getMetadata() {
     return metadata;
   }
-}
+}
@@ -13,7 +13,6 @@
 
 package io.dapr.client.domain;
 
-
 import com.fasterxml.jackson.annotation.JsonIgnore;
 
 import java.io.Serializable;

@@ -13,10 +13,8 @@
 
 package io.dapr.client.domain;
 
-
 public class QueryStateItem<T> {
 
-
   /**
    * The value of the state.
    */

@@ -13,7 +13,6 @@
 
 package io.dapr.client.domain;
 
-
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;

@@ -13,7 +13,6 @@
 
 package io.dapr.client.domain;
 
-
 public enum UnlockResponseStatus {
 
   /**

@@ -72,4 +72,4 @@ public Query setPagination(Pagination pagination) {
     this.pagination = pagination;
     return this;
   }
-}
+}
@@ -254,8 +254,6 @@ public class Properties {
           "DAPR_HTTP_CLIENT_MAX_IDLE_CONNECTIONS",
           DEFAULT_HTTP_CLIENT_MAX_IDLE_CONNECTIONS);
 
-
-
   /**
    * Dapr's default maximum inbound message size for GRPC in bytes.
    */

@@ -217,5 +217,4 @@ public enum ErrorDetailType {
     HELP,
     LOCALIZED_MESSAGE,
   }
-
-}
+}
@@ -62,7 +62,4 @@ public void onHeaders(Metadata headers) {
       }
     };
   }
-
-
-
 }
@@ -13,7 +13,6 @@
 
 package io.dapr.utils;
 
-
 import io.dapr.serializer.DefaultObjectSerializer;
 
 import java.io.IOException;
@@ -145,7 +144,6 @@ public static boolean isCloudEventContentType(String contentType) {
     return isContentType(contentType, "application/cloudevents+json");
   }
 
-
   public static boolean isJsonContentType(String contentType) {
     return isContentType(contentType, "application/json");
   }

@@ -50,7 +50,6 @@
 import static io.dapr.config.Properties.GRPC_TLS_KEY_PATH;
 import static io.dapr.config.Properties.SIDECAR_IP;
 
-
 /**
  * Utility methods for network, internal to Dapr SDK.
  */
@@ -382,4 +381,4 @@ public static String getHostLoopbackAddress() {
   static boolean isIPv6(String ip) {
     return IPV6_PATTERN.matcher(ip).matches();
   }
-}
+}
-Original file line number
+Diff line change
@@ Expand Up / @@ -23,7 +23,6 @@ public class DaprClientProperties { @@
       private Integer httpPort;
       private Integer grpcPort;
       /**
        * Constructs a {@link DaprClientProperties}.
        */
@@ Expand Down @@
Original file line number	Diff line number	Diff line change
Expand Up		@@ -15,7 +15,6 @@

		import org.springframework.boot.context.properties.ConfigurationProperties;


		@ConfigurationProperties(prefix = DaprPubSubProperties.CONFIG_PREFIX)
		public class DaprPubSubProperties {

Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -13,7 +13,6 @@

		package io.dapr.client.domain;


		import com.fasterxml.jackson.annotation.JsonIgnore;

		import java.io.Serializable;
Expand Down