Skip to content

Commit 7eb30dc

Browse files
Apply Palantir Java Format
1 parent 192831d commit 7eb30dc

33 files changed

Lines changed: 39 additions & 45 deletions

File tree

rqueue-core/src/main/java/com/github/sonus21/rqueue/core/impl/BaseMessageSender.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@
3333
import com.github.sonus21.rqueue.listener.QueueDetail;
3434
import com.github.sonus21.rqueue.models.db.MessageMetadata;
3535
import com.github.sonus21.rqueue.models.enums.MessageStatus;
36-
import com.github.sonus21.rqueue.utils.PriorityUtils;
3736
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
37+
import com.github.sonus21.rqueue.utils.PriorityUtils;
3838
import java.time.Duration;
3939
import java.util.Collections;
4040
import java.util.HashMap;

rqueue-core/src/main/java/com/github/sonus21/rqueue/core/impl/MessageSweeper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@
2222
import com.github.sonus21.rqueue.core.support.RqueueMessageUtils;
2323
import com.github.sonus21.rqueue.exception.UnknownSwitchCase;
2424
import com.github.sonus21.rqueue.listener.QueueDetail;
25+
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
2526
import com.github.sonus21.rqueue.utils.RetryableRunnable;
2627
import com.github.sonus21.rqueue.utils.StringUtils;
27-
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
2828
import java.util.ArrayList;
2929
import java.util.Arrays;
3030
import java.util.LinkedList;

rqueue-core/src/main/java/com/github/sonus21/rqueue/core/impl/RqueueEndpointManagerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,10 +26,10 @@
2626
import com.github.sonus21.rqueue.models.db.QueueConfig;
2727
import com.github.sonus21.rqueue.models.request.PauseUnpauseQueueRequest;
2828
import com.github.sonus21.rqueue.models.response.BaseResponse;
29+
import com.github.sonus21.rqueue.service.RqueueUtilityService;
2930
import com.github.sonus21.rqueue.utils.Constants;
3031
import com.github.sonus21.rqueue.utils.PriorityUtils;
3132
import com.github.sonus21.rqueue.utils.Validator;
32-
import com.github.sonus21.rqueue.service.RqueueUtilityService;
3333
import java.util.ArrayList;
3434
import java.util.Collections;
3535
import java.util.HashMap;

rqueue-core/src/main/java/com/github/sonus21/rqueue/listener/JobImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,9 +31,9 @@
3131
import com.github.sonus21.rqueue.models.enums.ExecutionStatus;
3232
import com.github.sonus21.rqueue.models.enums.JobStatus;
3333
import com.github.sonus21.rqueue.models.enums.MessageStatus;
34+
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
3435
import com.github.sonus21.rqueue.utils.Constants;
3536
import com.github.sonus21.rqueue.utils.TimeoutUtils;
36-
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
3737
import java.io.Serializable;
3838
import java.time.Duration;
3939
import java.util.List;

rqueue-core/src/main/java/com/github/sonus21/rqueue/utils/HttpUtils.java

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -38,22 +38,20 @@ private static HttpClient buildClient(RqueueConfig rqueueConfig) {
3838
HttpClient.Builder builder =
3939
HttpClient.newBuilder().connectTimeout(Duration.ofMillis(2 * Constants.ONE_MILLI_INT));
4040
if (!StringUtils.isEmpty(rqueueConfig.getProxyHost())) {
41-
builder.proxy(
42-
ProxySelector.of(
43-
new InetSocketAddress(rqueueConfig.getProxyHost(), rqueueConfig.getProxyPort())));
41+
builder.proxy(ProxySelector.of(
42+
new InetSocketAddress(rqueueConfig.getProxyHost(), rqueueConfig.getProxyPort())));
4443
}
4544
return builder.build();
4645
}
4746

4847
public static <T> T readUrl(RqueueConfig rqueueConfig, String url, Class<T> clazz) {
4948
try {
5049
HttpClient client = buildClient(rqueueConfig);
51-
HttpRequest request =
52-
HttpRequest.newBuilder(URI.create(url))
53-
.timeout(Duration.ofMillis(2 * Constants.ONE_MILLI_INT))
54-
.header("Accept", "application/json")
55-
.GET()
56-
.build();
50+
HttpRequest request = HttpRequest.newBuilder(URI.create(url))
51+
.timeout(Duration.ofMillis(2 * Constants.ONE_MILLI_INT))
52+
.header("Accept", "application/json")
53+
.GET()
54+
.build();
5755
HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
5856
if (response.statusCode() / 100 != 2) {
5957
log.error("GET {} returned status {}", url, response.statusCode());

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/RqueueMessageEnqueuerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,8 @@
2828
import com.github.sonus21.rqueue.config.RqueueConfig;
2929
import com.github.sonus21.rqueue.core.impl.RqueueMessageEnqueuerImpl;
3030
import com.github.sonus21.rqueue.listener.QueueDetail;
31-
import com.github.sonus21.rqueue.utils.TestUtils;
3231
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
32+
import com.github.sonus21.rqueue.utils.TestUtils;
3333
import org.junit.jupiter.api.BeforeEach;
3434
import org.junit.jupiter.api.Test;
3535
import org.mockito.Mock;

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/impl/BaseMessageSenderMetadataTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@
3636
import com.github.sonus21.rqueue.core.spi.MessageBroker;
3737
import com.github.sonus21.rqueue.listener.QueueDetail;
3838
import com.github.sonus21.rqueue.listener.RqueueMessageHeaders;
39-
import com.github.sonus21.rqueue.utils.TestUtils;
4039
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
40+
import com.github.sonus21.rqueue.utils.TestUtils;
4141
import org.apache.commons.lang3.reflect.FieldUtils;
4242
import org.junit.jupiter.api.AfterAll;
4343
import org.junit.jupiter.api.BeforeAll;

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/impl/ReactiveRqueueMessageEnqueuerBrokerRoutingTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@
3636
import com.github.sonus21.rqueue.core.spi.MessageBroker;
3737
import com.github.sonus21.rqueue.listener.QueueDetail;
3838
import com.github.sonus21.rqueue.listener.RqueueMessageHeaders;
39-
import com.github.sonus21.rqueue.utils.TestUtils;
4039
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
40+
import com.github.sonus21.rqueue.utils.TestUtils;
4141
import org.apache.commons.lang3.reflect.FieldUtils;
4242
import org.junit.jupiter.api.AfterAll;
4343
import org.junit.jupiter.api.BeforeAll;

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/impl/RqueueEndpointManagerImplTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,9 +34,9 @@
3434
import com.github.sonus21.rqueue.models.db.QueueConfig;
3535
import com.github.sonus21.rqueue.models.request.PauseUnpauseQueueRequest;
3636
import com.github.sonus21.rqueue.models.response.BaseResponse;
37+
import com.github.sonus21.rqueue.service.RqueueUtilityService;
3738
import com.github.sonus21.rqueue.utils.PriorityUtils;
3839
import com.github.sonus21.rqueue.utils.TestUtils;
39-
import com.github.sonus21.rqueue.service.RqueueUtilityService;
4040
import org.apache.commons.lang3.reflect.FieldUtils;
4141
import org.junit.jupiter.api.AfterEach;
4242
import org.junit.jupiter.api.BeforeEach;

rqueue-core/src/test/java/com/github/sonus21/rqueue/core/impl/RqueueMessageEnqueuerImplTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,9 +34,9 @@
3434
import com.github.sonus21.rqueue.listener.QueueDetail;
3535
import com.github.sonus21.rqueue.listener.RqueueMessageHeaders;
3636
import com.github.sonus21.rqueue.models.db.MessageMetadata;
37+
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
3738
import com.github.sonus21.rqueue.utils.Constants;
3839
import com.github.sonus21.rqueue.utils.TestUtils;
39-
import com.github.sonus21.rqueue.service.RqueueMessageMetadataService;
4040
import java.util.UUID;
4141
import org.apache.commons.lang3.reflect.FieldUtils;
4242
import org.junit.jupiter.api.AfterAll;

0 commit comments

Comments
 (0)