mirror of https://github.com/dapr/java-sdk.git
Make sure there no multiple empty lines and every file ends with a new line (#1417)
Signed-off-by: sirivarma <siri.varma@outlook.com>
This commit is contained in:
parent
d7e7205c17
commit
0dd37f95da
|
|
@ -112,6 +112,7 @@
|
||||||
<module name="ModifierOrder"/>
|
<module name="ModifierOrder"/>
|
||||||
<module name="EmptyLineSeparator">
|
<module name="EmptyLineSeparator">
|
||||||
<property name="allowNoEmptyLineBetweenFields" value="true"/>
|
<property name="allowNoEmptyLineBetweenFields" value="true"/>
|
||||||
|
<property name="allowMultipleEmptyLines" value="false"/>
|
||||||
</module>
|
</module>
|
||||||
<module name="SeparatorWrap">
|
<module name="SeparatorWrap">
|
||||||
<property name="id" value="SeparatorWrapDot"/>
|
<property name="id" value="SeparatorWrapDot"/>
|
||||||
|
|
@ -287,4 +288,5 @@
|
||||||
<module name="SuppressWarningsHolder"/>
|
<module name="SuppressWarningsHolder"/>
|
||||||
</module>
|
</module>
|
||||||
<module name="SuppressWarningsFilter"/>
|
<module name="SuppressWarningsFilter"/>
|
||||||
|
<module name="NewlineAtEndOfFile"/>
|
||||||
</module>
|
</module>
|
||||||
|
|
|
||||||
|
|
@ -23,7 +23,6 @@ public class DaprClientProperties {
|
||||||
private Integer httpPort;
|
private Integer httpPort;
|
||||||
private Integer grpcPort;
|
private Integer grpcPort;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Constructs a {@link DaprClientProperties}.
|
* Constructs a {@link DaprClientProperties}.
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -15,7 +15,6 @@ package io.dapr.spring.boot.autoconfigure.pubsub;
|
||||||
|
|
||||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||||
|
|
||||||
|
|
||||||
@ConfigurationProperties(prefix = DaprPubSubProperties.CONFIG_PREFIX)
|
@ConfigurationProperties(prefix = DaprPubSubProperties.CONFIG_PREFIX)
|
||||||
public class DaprPubSubProperties {
|
public class DaprPubSubProperties {
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -76,7 +76,6 @@ public class MySQLDaprKeyValueAdapter extends AbstractDaprKeyValueAdapter {
|
||||||
this.bindingName = bindingName;
|
this.bindingName = bindingName;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public <T> Iterable<T> getAllOf(String keyspace, Class<T> type) {
|
public <T> Iterable<T> getAllOf(String keyspace, Class<T> type) {
|
||||||
Assert.hasText(keyspace, "Keyspace must not be empty");
|
Assert.hasText(keyspace, "Keyspace must not be empty");
|
||||||
|
|
|
||||||
|
|
@ -18,7 +18,6 @@ public class DaprPredicate implements Predicate<Object> {
|
||||||
this(path, expected, (valueToCompare) -> ObjectUtils.nullSafeEquals(valueToCompare, expected));
|
this(path, expected, (valueToCompare) -> ObjectUtils.nullSafeEquals(valueToCompare, expected));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new {@link DaprPredicate}.
|
* Creates a new {@link DaprPredicate}.
|
||||||
*
|
*
|
||||||
|
|
|
||||||
|
|
@ -192,7 +192,6 @@ public class DaprMessagingTemplate<T> implements DaprMessagingOperations<T>, App
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void send() {
|
public void send() {
|
||||||
template.doSend(topic, message);
|
template.doSend(topic, message);
|
||||||
|
|
@ -202,7 +201,5 @@ public class DaprMessagingTemplate<T> implements DaprMessagingOperations<T>, App
|
||||||
public Mono<Void> sendAsync() {
|
public Mono<Void> sendAsync() {
|
||||||
return template.doSendAsync(topic, message);
|
return template.doSendAsync(topic, message);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -58,7 +58,6 @@ public final class DaprMessagingSenderContext extends SenderContext<DaprMessagin
|
||||||
return carrier.properties();
|
return carrier.properties();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* The name of the bean sending the message (typically a {@code DaprMessagingTemplate}).
|
* The name of the bean sending the message (typically a {@code DaprMessagingTemplate}).
|
||||||
* @return the name of the bean sending the message
|
* @return the name of the bean sending the message
|
||||||
|
|
@ -75,7 +74,6 @@ public final class DaprMessagingSenderContext extends SenderContext<DaprMessagin
|
||||||
return this.destination;
|
return this.destination;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Acts as a carrier for a Dapr message and records the propagated properties for
|
* Acts as a carrier for a Dapr message and records the propagated properties for
|
||||||
* later access by the Dapr.
|
* later access by the Dapr.
|
||||||
|
|
|
||||||
|
|
@ -1,6 +1,5 @@
|
||||||
package io.dapr.spring.workflows.config;
|
package io.dapr.spring.workflows.config;
|
||||||
|
|
||||||
|
|
||||||
import org.springframework.context.annotation.Import;
|
import org.springframework.context.annotation.Import;
|
||||||
|
|
||||||
import java.lang.annotation.Retention;
|
import java.lang.annotation.Retention;
|
||||||
|
|
|
||||||
|
|
@ -13,6 +13,7 @@ limitations under the License.
|
||||||
|
|
||||||
package io.dapr.examples.workflows.childworkflow;
|
package io.dapr.examples.workflows.childworkflow;
|
||||||
|
|
||||||
|
import io.dapr.durabletask.interruption.OrchestratorBlockedException;
|
||||||
import io.dapr.workflows.Workflow;
|
import io.dapr.workflows.Workflow;
|
||||||
import io.dapr.workflows.WorkflowStub;
|
import io.dapr.workflows.WorkflowStub;
|
||||||
import io.dapr.workflows.WorkflowTaskOptions;
|
import io.dapr.workflows.WorkflowTaskOptions;
|
||||||
|
|
|
||||||
|
|
@ -123,7 +123,6 @@ public class ActorId extends Object implements Comparable<ActorId> {
|
||||||
return new ActorId(id.toString());
|
return new ActorId(id.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Compares if two actors have the same content.
|
* Compares if two actors have the same content.
|
||||||
*
|
*
|
||||||
|
|
|
||||||
|
|
@ -130,7 +130,6 @@ public class ActorClient implements AutoCloseable {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Build an instance of the Client based on the provided setup.
|
* Build an instance of the Client based on the provided setup.
|
||||||
*
|
*
|
||||||
|
|
|
||||||
|
|
@ -13,7 +13,6 @@ limitations under the License.
|
||||||
|
|
||||||
package io.dapr.springboot;
|
package io.dapr.springboot;
|
||||||
|
|
||||||
|
|
||||||
import io.dapr.actors.runtime.ActorRuntime;
|
import io.dapr.actors.runtime.ActorRuntime;
|
||||||
import io.dapr.serializer.DefaultObjectSerializer;
|
import io.dapr.serializer.DefaultObjectSerializer;
|
||||||
import org.springframework.http.MediaType;
|
import org.springframework.http.MediaType;
|
||||||
|
|
@ -124,5 +123,4 @@ public class DaprController {
|
||||||
@RequestBody(required = false) byte[] body) {
|
@RequestBody(required = false) byte[] body) {
|
||||||
return ActorRuntime.getInstance().invokeReminder(type, id, reminder, body);
|
return ActorRuntime.getInstance().invokeReminder(type, id, reminder, body);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -123,7 +123,6 @@ class DaprTopicSubscription {
|
||||||
this(pubsubName, topic, route, "", routes, metadata, bulkSubscribe);
|
this(pubsubName, topic, route, "", routes, metadata, bulkSubscribe);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Create a subscription topic.
|
* Create a subscription topic.
|
||||||
*
|
*
|
||||||
|
|
|
||||||
|
|
@ -48,7 +48,6 @@ public class WorkflowActivityClassWrapper<T extends WorkflowActivity> implements
|
||||||
return name;
|
return name;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public TaskActivity create() {
|
public TaskActivity create() {
|
||||||
return ctx -> {
|
return ctx -> {
|
||||||
|
|
|
||||||
|
|
@ -655,7 +655,6 @@ abstract class AbstractDaprClient implements DaprClient, DaprPreviewClient {
|
||||||
return this.unlock(request);
|
return this.unlock(request);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
private List<String> filterEmptyKeys(String... keys) {
|
private List<String> filterEmptyKeys(String... keys) {
|
||||||
return Arrays.stream(keys)
|
return Arrays.stream(keys)
|
||||||
.filter(key -> !key.trim().isEmpty())
|
.filter(key -> !key.trim().isEmpty())
|
||||||
|
|
|
||||||
|
|
@ -32,7 +32,6 @@ class GrpcChannelFacade implements Closeable {
|
||||||
*/
|
*/
|
||||||
private final ManagedChannel channel;
|
private final ManagedChannel channel;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Default access level constructor, in order to create an instance of this class use io.dapr.client.DaprClientBuilder
|
* Default access level constructor, in order to create an instance of this class use io.dapr.client.DaprClientBuilder
|
||||||
*
|
*
|
||||||
|
|
|
||||||
|
|
@ -81,7 +81,6 @@ public final class BulkPublishEntry<T> {
|
||||||
return event;
|
return event;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public String getContentType() {
|
public String getContentType() {
|
||||||
return contentType;
|
return contentType;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -13,7 +13,6 @@ limitations under the License.
|
||||||
|
|
||||||
package io.dapr.client.domain;
|
package io.dapr.client.domain;
|
||||||
|
|
||||||
|
|
||||||
import com.fasterxml.jackson.annotation.JsonIgnore;
|
import com.fasterxml.jackson.annotation.JsonIgnore;
|
||||||
|
|
||||||
import java.io.Serializable;
|
import java.io.Serializable;
|
||||||
|
|
|
||||||
|
|
@ -13,10 +13,8 @@ limitations under the License.
|
||||||
|
|
||||||
package io.dapr.client.domain;
|
package io.dapr.client.domain;
|
||||||
|
|
||||||
|
|
||||||
public class QueryStateItem<T> {
|
public class QueryStateItem<T> {
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* The value of the state.
|
* The value of the state.
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -13,7 +13,6 @@ limitations under the License.
|
||||||
|
|
||||||
package io.dapr.client.domain;
|
package io.dapr.client.domain;
|
||||||
|
|
||||||
|
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
|
||||||
|
|
@ -13,7 +13,6 @@ limitations under the License.
|
||||||
|
|
||||||
package io.dapr.client.domain;
|
package io.dapr.client.domain;
|
||||||
|
|
||||||
|
|
||||||
public enum UnlockResponseStatus {
|
public enum UnlockResponseStatus {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
|
|
@ -254,8 +254,6 @@ public class Properties {
|
||||||
"DAPR_HTTP_CLIENT_MAX_IDLE_CONNECTIONS",
|
"DAPR_HTTP_CLIENT_MAX_IDLE_CONNECTIONS",
|
||||||
DEFAULT_HTTP_CLIENT_MAX_IDLE_CONNECTIONS);
|
DEFAULT_HTTP_CLIENT_MAX_IDLE_CONNECTIONS);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Dapr's default maximum inbound message size for GRPC in bytes.
|
* Dapr's default maximum inbound message size for GRPC in bytes.
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -217,5 +217,4 @@ public class DaprErrorDetails {
|
||||||
HELP,
|
HELP,
|
||||||
LOCALIZED_MESSAGE,
|
LOCALIZED_MESSAGE,
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
@ -62,7 +62,4 @@ public class DaprMetadataReceiverInterceptor implements ClientInterceptor {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -13,7 +13,6 @@ limitations under the License.
|
||||||
|
|
||||||
package io.dapr.utils;
|
package io.dapr.utils;
|
||||||
|
|
||||||
|
|
||||||
import io.dapr.serializer.DefaultObjectSerializer;
|
import io.dapr.serializer.DefaultObjectSerializer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
@ -145,7 +144,6 @@ public class DefaultContentTypeConverter {
|
||||||
return isContentType(contentType, "application/cloudevents+json");
|
return isContentType(contentType, "application/cloudevents+json");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public static boolean isJsonContentType(String contentType) {
|
public static boolean isJsonContentType(String contentType) {
|
||||||
return isContentType(contentType, "application/json");
|
return isContentType(contentType, "application/json");
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -50,7 +50,6 @@ import static io.dapr.config.Properties.GRPC_TLS_INSECURE;
|
||||||
import static io.dapr.config.Properties.GRPC_TLS_KEY_PATH;
|
import static io.dapr.config.Properties.GRPC_TLS_KEY_PATH;
|
||||||
import static io.dapr.config.Properties.SIDECAR_IP;
|
import static io.dapr.config.Properties.SIDECAR_IP;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Utility methods for network, internal to Dapr SDK.
|
* Utility methods for network, internal to Dapr SDK.
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue