Skip to content

Commit ecd9070

Browse files
Apply Palantir Java Format
1 parent 11593ad commit ecd9070

2 files changed

Lines changed: 6 additions & 3 deletions

File tree

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -401,12 +401,14 @@ void middlewareRunsWhenMessageConverterThrows() {
401401
// built above with the working converter, so only the inbound conversion fails.
402402
MessageConverter throwingConverter = new MessageConverter() {
403403
@Override
404-
public Object fromMessage(org.springframework.messaging.Message<?> message, Class<?> targetClass) {
404+
public Object fromMessage(
405+
org.springframework.messaging.Message<?> message, Class<?> targetClass) {
405406
throw new IllegalStateException("boom: converter failed");
406407
}
407408

408409
@Override
409-
public org.springframework.messaging.Message<?> toMessage(Object payload, org.springframework.messaging.MessageHeaders headers) {
410+
public org.springframework.messaging.Message<?> toMessage(
411+
Object payload, org.springframework.messaging.MessageHeaders headers) {
410412
return null;
411413
}
412414
};

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,8 @@ void peekRoutesThroughBrokerForReadyList() {
193193
DataViewResponse response = service.getExplorePageData(
194194
queueConfig.getName(), queueConfig.getQueueName(), DataType.LIST, null, 0, 10);
195195

196-
verify(messageBroker, atLeastOnce()).peek(any(QueueDetail.class), nullable(String.class), anyLong(), anyLong());
196+
verify(messageBroker, atLeastOnce())
197+
.peek(any(QueueDetail.class), nullable(String.class), anyLong(), anyLong());
197198
assertTrue(response.getRows() == null || response.getRows().isEmpty());
198199
}
199200

0 commit comments

Comments
 (0)