Skip to content

Commit bb1ef19

Browse files
Apply Palantir Java Format
1 parent 823e2b1 commit bb1ef19

3 files changed

Lines changed: 10 additions & 5 deletions

File tree

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -313,8 +313,8 @@ private MappingInformation getMappingInformation(RqueueListener rqueueListener)
313313
Map<String, Integer> priorityMap = resolvePriority(rqueueListener);
314314
String priorityGroup = resolvePriorityGroup(rqueueListener);
315315
int batchSize = getBatchSize(rqueueListener, concurrency);
316-
String natsConsumerName = ValueResolver.resolveKeyToString(
317-
getApplicationContext(), rqueueListener.consumerName());
316+
String natsConsumerName =
317+
ValueResolver.resolveKeyToString(getApplicationContext(), rqueueListener.consumerName());
318318
MappingInformation mappingInformation = MappingInformation.builder()
319319
.active(active)
320320
.concurrency(concurrency)

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,8 +59,9 @@ abstract class RqueueMessagePoller extends MessageContainerBase {
5959
}
6060

6161
private List<RqueueMessage> getMessages(QueueDetail queueDetail, int count) {
62-
return rqueueBeanProvider.getMessageBroker().pop(
63-
queueDetail, queueDetail.getNatsConsumerName(), count, Duration.ZERO);
62+
return rqueueBeanProvider
63+
.getMessageBroker()
64+
.pop(queueDetail, queueDetail.getNatsConsumerName(), count, Duration.ZERO);
6465
}
6566

6667
private void execute(

rqueue-nats/src/test/java/com/github/sonus21/rqueue/nats/JetStreamMessageBrokerUnitTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,11 @@ private static Fixture newFixture(RqueueNatsConfig config) {
6262
// naming and exception wrapping, not stream creation.
6363
NatsProvisioner provisioner = mock(NatsProvisioner.class);
6464
JetStreamMessageBroker broker = new JetStreamMessageBroker(
65-
conn, js, jsm, config, new RqJacksonSerDes(SerializationUtils.getObjectMapper()),
65+
conn,
66+
js,
67+
jsm,
68+
config,
69+
new RqJacksonSerDes(SerializationUtils.getObjectMapper()),
6670
provisioner);
6771
return new Fixture(conn, js, jsm, broker);
6872
}

0 commit comments

Comments
 (0)