Skip to content

Commit 5630a7a

Browse files
JaidenAshmoreJaidenAshmore
authored
refs #408: upgrade dependencies (#409)
1 parent 87d6e9e commit 5630a7a

File tree

37 files changed

+168
-78
lines changed

37 files changed

+168
-78
lines changed

‎build.gradle.kts

-9
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
import com.jashmore.gradle.JacocoCoverallsPlugin
22
import com.jashmore.gradle.ReleasePlugin
33
import com.jashmore.gradle.release
4-
import io.gitlab.arturbosch.detekt.detekt
54

65
plugins {
76
java
@@ -12,7 +11,6 @@ plugins {
1211
id("com.github.spotbugs")
1312
id("com.jashmore.gradle.github.release")
1413
id("org.jlleitschuh.gradle.ktlint") apply false
15-
id("io.gitlab.arturbosch.detekt") apply false
1614
id("org.unbroken-dome.test-sets") version "4.0.0"
1715
}
1816

@@ -46,7 +44,6 @@ subprojects {
4644
}
4745
} else {
4846
apply(plugin = "org.jlleitschuh.gradle.ktlint")
49-
apply(plugin = "io.gitlab.arturbosch.detekt")
5047
}
5148

5249
dependencies {
@@ -86,12 +83,6 @@ subprojects {
8683
excludeFilter.set(file("${project.rootDir}/configuration/spotbugs/bugsExcludeFilter.xml"))
8784
}
8885
}
89-
} else {
90-
detekt {
91-
failFast = true
92-
buildUponDefaultConfig = true
93-
config = files("${project.rootDir}/configuration/detekt/detekt-configuration.yml")
94-
}
9586
}
9687

9788
tasks.withType<Test> {

‎configuration/detekt/detekt-configuration.yml

-7
This file was deleted.

‎configuration/spotbugs/bugsExcludeFilter.xml

+1
Original file line numberDiff line numberDiff line change
@@ -10,5 +10,6 @@
1010
</Match>
1111
<Match>
1212
<Source name="~.*generated-sources.*" />
13+
<Source name="~.*generated-test-sources.*" />
1314
</Match>
1415
</FindBugsFilter>

‎core/src/main/java/com/jashmore/sqs/retriever/batching/BatchingMessageRetriever.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import software.amazon.awssdk.core.exception.SdkInterruptedException;
2424
import software.amazon.awssdk.services.sqs.SqsAsyncClient;
2525
import software.amazon.awssdk.services.sqs.model.Message;
26+
import software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName;
2627
import software.amazon.awssdk.services.sqs.model.QueueAttributeName;
2728
import software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest;
2829
import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
@@ -187,7 +188,7 @@ private ReceiveMessageRequest buildReceiveMessageRequest(final int numberOfMessa
187188
final ReceiveMessageRequest.Builder requestBuilder = ReceiveMessageRequest
188189
.builder()
189190
.queueUrl(queueProperties.getQueueUrl())
190-
.attributeNames(QueueAttributeName.ALL)
191+
.messageSystemAttributeNames(MessageSystemAttributeName.ALL)
191192
.messageAttributeNames(QueueAttributeName.ALL.toString())
192193
.maxNumberOfMessages(numberOfMessagesToObtain)
193194
.waitTimeSeconds(MAX_SQS_RECEIVE_WAIT_TIME_IN_SECONDS);

‎core/src/main/java/com/jashmore/sqs/retriever/prefetch/PrefetchingMessageRetriever.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import software.amazon.awssdk.core.exception.SdkInterruptedException;
2121
import software.amazon.awssdk.services.sqs.SqsAsyncClient;
2222
import software.amazon.awssdk.services.sqs.model.Message;
23+
import software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName;
2324
import software.amazon.awssdk.services.sqs.model.QueueAttributeName;
2425
import software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest;
2526
import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
@@ -166,7 +167,7 @@ private ReceiveMessageRequest buildReceiveMessageRequest() {
166167
final ReceiveMessageRequest.Builder requestBuilder = ReceiveMessageRequest
167168
.builder()
168169
.queueUrl(queueProperties.getQueueUrl())
169-
.attributeNames(QueueAttributeName.ALL)
170+
.messageSystemAttributeNames(MessageSystemAttributeName.ALL)
170171
.messageAttributeNames(QueueAttributeName.ALL.toString())
171172
.waitTimeSeconds(MAX_SQS_RECEIVE_WAIT_TIME_IN_SECONDS)
172173
.maxNumberOfMessages(numberOfMessagesToObtain);

‎core/src/test/java/com/jashmore/sqs/retriever/batching/BatchingMessageRetrieverTest.java

+5-4
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
import org.mockito.junit.jupiter.MockitoExtension;
2828
import software.amazon.awssdk.services.sqs.SqsAsyncClient;
2929
import software.amazon.awssdk.services.sqs.model.Message;
30-
import software.amazon.awssdk.services.sqs.model.QueueAttributeName;
30+
import software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName;
3131
import software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest;
3232
import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
3333

@@ -453,8 +453,8 @@ void allMessageAttributesShouldBeDownloadedWhenRequestingMessages() {
453453
ReceiveMessageRequest.class
454454
);
455455
verify(sqsAsyncClient).receiveMessage(receiveMessageRequestArgumentCaptor.capture());
456-
assertThat(receiveMessageRequestArgumentCaptor.getValue().messageAttributeNames())
457-
.containsExactly(QueueAttributeName.ALL.toString());
456+
assertThat(receiveMessageRequestArgumentCaptor.getValue().messageSystemAttributeNames())
457+
.containsExactly(MessageSystemAttributeName.ALL);
458458
}
459459

460460
@Test
@@ -483,7 +483,8 @@ void allMessageSystemAttributesShouldBeDownloadedWhenRequestingMessages() {
483483
ReceiveMessageRequest.class
484484
);
485485
verify(sqsAsyncClient).receiveMessage(receiveMessageRequestArgumentCaptor.capture());
486-
assertThat(receiveMessageRequestArgumentCaptor.getValue().attributeNames()).containsExactly(QueueAttributeName.ALL);
486+
assertThat(receiveMessageRequestArgumentCaptor.getValue().messageSystemAttributeNames())
487+
.containsExactly(MessageSystemAttributeName.ALL);
487488
}
488489

489490
@Test

‎core/src/test/java/com/jashmore/sqs/retriever/prefetch/PrefetchingMessageRetrieverTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
import software.amazon.awssdk.core.exception.SdkInterruptedException;
3838
import software.amazon.awssdk.services.sqs.SqsAsyncClient;
3939
import software.amazon.awssdk.services.sqs.model.Message;
40+
import software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName;
4041
import software.amazon.awssdk.services.sqs.model.QueueAttributeName;
4142
import software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest;
4243
import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
@@ -406,8 +407,7 @@ void allMessageAttributesAreIncludedInMessagesWhenRetrieved() {
406407
ReceiveMessageRequest.class
407408
);
408409
verify(sqsAsyncClient).receiveMessage(receiveMessageRequestArgumentCaptor.capture());
409-
assertThat(receiveMessageRequestArgumentCaptor.getValue().messageAttributeNames())
410-
.containsExactly(QueueAttributeName.ALL.toString());
410+
assertThat(receiveMessageRequestArgumentCaptor.getValue().messageAttributeNames()).contains(QueueAttributeName.ALL.toString());
411411
}
412412

413413
@Test
@@ -428,7 +428,7 @@ void allMessageSystemAttributesAreIncludedInMessagesWhenRetrieved() {
428428
ReceiveMessageRequest.class
429429
);
430430
verify(sqsAsyncClient).receiveMessage(receiveMessageRequestArgumentCaptor.capture());
431-
assertThat(receiveMessageRequestArgumentCaptor.getValue().attributeNames()).contains(QueueAttributeName.ALL);
431+
assertThat(receiveMessageRequestArgumentCaptor.getValue().messageSystemAttributeNames()).contains(MessageSystemAttributeName.ALL);
432432
}
433433

434434
@Test

‎doc/how-to-guides/spring/spring-how-to-version-payload-schemas-using-spring-cloud-schema-registry.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
# Spring - How to version message payload Schemas using Spring Cloud Schema Registry
22

33
As your application grows over time the format of the data that needs to be sent in the SQS messages may change as well. To allow for
4-
these changes, the [Spring Cloud Schema Registry](https://cloud.spring.io/spring-cloud-static/spring-cloud-schema-registry/1.0.0.RC1/reference/html/spring-cloud-schema-registry.html)
4+
these changes, the [Spring Cloud Schema Registry](https://docs.spring.io/spring-cloud-schema-registry/docs/current/reference/html/spring-cloud-schema-registry.html)
55
can be used to track the version of your schemas, allowing the SQS consumer to be able to interpret multiple versions of your payload.
66

77
## Full reference

‎examples/core-kotlin-example/src/main/kotlin/com/jashmore/sqs/examples/KotlinConcurrentBrokerExample.kt

+1-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ private val log: Logger = LoggerFactory.getLogger("example")
2929
private val CONCURRENCY_LEVEL_PERIOD = Duration.ofSeconds(5)
3030
private const val CONCURRENCY_LIMIT = 10
3131

32-
private val objectMapper = ObjectMapper().registerModule(KotlinModule())
32+
private val objectMapper = ObjectMapper().registerModule(KotlinModule.Builder().build())
3333

3434
/**
3535
* This example shows the core framework being used to processing messages place onto the queue with a dynamic level of concurrency via the

‎examples/spring-cloud-schema-registry-example/README.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
This example shows how you can consume messages which have been defined using an [Avro](https://avro.apache.org/docs/1.9.2/gettingstartedjava.html)
44
Schema and
5-
the [Spring Cloud Schema Registry](https://cloud.spring.io/spring-cloud-static/spring-cloud-schema-registry/1.0.0.RC1/reference/html/spring-cloud-schema-registry.html).
5+
the [Spring Cloud Schema Registry](https://docs.spring.io/spring-cloud-schema-registry/docs/current/reference/html/spring-cloud-schema-registry.html).
66

77
To find the corresponding code look in the [Spring Cloud Schema Registry Extension](../../extensions/spring-cloud-schema-registry-extension) module.
88

‎examples/spring-starter-example/src/main/java/com/jashmore/sqs/examples/Application.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
11
package com.jashmore.sqs.examples;
22

3-
import akka.http.scaladsl.Http;
43
import com.jashmore.sqs.spring.config.QueueListenerConfiguration;
54
import com.jashmore.sqs.spring.container.basic.QueueListener;
65
import com.jashmore.sqs.spring.container.prefetch.PrefetchingQueueListener;
76
import com.jashmore.sqs.util.LocalSqsAsyncClientImpl;
87
import com.jashmore.sqs.util.SqsQueuesConfig;
98
import lombok.extern.slf4j.Slf4j;
9+
import org.apache.pekko.http.scaladsl.Http;
1010
import org.elasticmq.rest.sqs.SQSRestServer;
1111
import org.elasticmq.rest.sqs.SQSRestServerBuilder;
1212
import org.springframework.boot.SpringApplication;

‎extensions/aws-xray-extension/core/build.gradle.kts

+9
Original file line numberDiff line numberDiff line change
@@ -13,3 +13,12 @@ dependencies {
1313
testImplementation(project(":java-dynamic-sqs-listener-core"))
1414
testImplementation(project(":expected-test-exception"))
1515
}
16+
17+
configurations.all {
18+
resolutionStrategy.eachDependency {
19+
// xray requires an older version of jackson
20+
if (requested.group.startsWith("com.fasterxml.jackson")) {
21+
useVersion("2.15.2")
22+
}
23+
}
24+
}

‎extensions/aws-xray-extension/spring-boot/build.gradle.kts

+9
Original file line numberDiff line numberDiff line change
@@ -16,3 +16,12 @@ dependencies {
1616
testImplementation("org.springframework.boot:spring-boot-test")
1717
testImplementation(project(":elasticmq-sqs-client"))
1818
}
19+
20+
configurations.all {
21+
resolutionStrategy.eachDependency {
22+
// xray requires an older version of jackson
23+
if (requested.group.startsWith("com.fasterxml.jackson")) {
24+
useVersion("2.15.2")
25+
}
26+
}
27+
}

‎extensions/aws-xray-extension/spring-boot/src/integrationTest/java/com/jashmore/sqs/extensions/xray/XrayExtensionIntegrationTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public LocalSqsAsyncClient localSqsAsyncClient() {
5151

5252
@Bean
5353
@Qualifier("sqsXrayRecorder")
54-
public AWSXRayRecorder recorder() throws IOException {
54+
public AWSXRayRecorder sqsXrayRecorder() throws IOException {
5555
final DaemonConfiguration daemonConfiguration = new DaemonConfiguration();
5656
daemonConfiguration.setDaemonAddress("localhost:" + XRAY_DAEMON_PORT);
5757
final AWSXRayRecorder recorder = AWSXRayRecorderBuilder.standard().withEmitter(Emitter.create(daemonConfiguration)).build();

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/argument/CoreArgumentResolverServiceDslBuilder.kt

+7-2
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,9 @@ import com.jashmore.sqs.processor.MessageProcessor
1313
* [ArgumentResolverServiceDslBuilder] that constructs a [CoreArgumentResolverService] for the [MessageProcessor].
1414
*/
1515
@MessageListenerComponentDslMarker
16-
class CoreArgumentResolverServiceDslBuilder(private val objectMapper: ObjectMapper) : ArgumentResolverServiceDslBuilder {
16+
class CoreArgumentResolverServiceDslBuilder(
17+
private val objectMapper: ObjectMapper
18+
) : ArgumentResolverServiceDslBuilder {
1719

1820
override fun invoke(): ArgumentResolverService {
1921
return CoreArgumentResolverService(
@@ -33,5 +35,8 @@ class CoreArgumentResolverServiceDslBuilder(private val objectMapper: ObjectMapp
3335
*
3436
* @param init the DSL function for configuring this processor
3537
*/
36-
fun coreArgumentResolverService(objectMapper: ObjectMapper = ObjectMapper(), init: CoreArgumentResolverServiceDslBuilder.() -> Unit = { }) =
38+
fun coreArgumentResolverService(
39+
objectMapper: ObjectMapper = ObjectMapper(),
40+
init: CoreArgumentResolverServiceDslBuilder.() -> Unit = { }
41+
) =
3742
initComponent(CoreArgumentResolverServiceDslBuilder(objectMapper), init)

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/broker/ConcurrentMessageBrokerDslBuilder.kt

+3-1
Original file line numberDiff line numberDiff line change
@@ -69,4 +69,6 @@ class ConcurrentMessageBrokerDslBuilder : MessageBrokerDslBuilder {
6969
* }
7070
* ```
7171
*/
72-
fun concurrentBroker(init: ConcurrentMessageBrokerDslBuilder.() -> Unit) = initComponent(ConcurrentMessageBrokerDslBuilder(), init)
72+
fun concurrentBroker(
73+
init: ConcurrentMessageBrokerDslBuilder.() -> Unit
74+
) = initComponent(ConcurrentMessageBrokerDslBuilder(), init)

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/broker/GroupingMessageBrokerDslBuilder.kt

+8-2
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,11 @@ class GroupingMessageBrokerDslBuilder : MessageBrokerDslBuilder {
7878

7979
override fun getMaximumNumberOfCachedMessageGroups(): Int = maximumNumberOfCachedMessageGroups()
8080

81-
override fun messageGroupingFunction(): Function<Message, String> = Function { t -> actualMessageGroupingFunction(t) }
81+
override fun messageGroupingFunction(): Function<Message, String> = Function { t ->
82+
actualMessageGroupingFunction(
83+
t
84+
)
85+
}
8286
}
8387
)
8488
}
@@ -94,4 +98,6 @@ class GroupingMessageBrokerDslBuilder : MessageBrokerDslBuilder {
9498
* }
9599
* ```
96100
*/
97-
fun groupingBroker(init: GroupingMessageBrokerDslBuilder.() -> Unit) = initComponent(GroupingMessageBrokerDslBuilder(), init)
101+
fun groupingBroker(
102+
init: GroupingMessageBrokerDslBuilder.() -> Unit
103+
) = initComponent(GroupingMessageBrokerDslBuilder(), init)

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/container/AbstractMessageListenerContainerDslBuilder.kt

+11-2
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,11 @@ import software.amazon.awssdk.services.sqs.SqsAsyncClient
1818
*
1919
* <p>This only provides access to the processor object
2020
*/
21-
abstract class AbstractMessageListenerContainerDslBuilder(val identifier: String, val sqsAsyncClient: SqsAsyncClient, val queueProperties: QueueProperties) :
21+
abstract class AbstractMessageListenerContainerDslBuilder(
22+
val identifier: String,
23+
val sqsAsyncClient: SqsAsyncClient,
24+
val queueProperties: QueueProperties
25+
) :
2226
MessageListenerComponentDslBuilder<MessageListenerContainer> {
2327
var processor: MessageProcessorDslBuilder? = null
2428

@@ -72,5 +76,10 @@ abstract class AbstractMessageListenerContainerDslBuilder(val identifier: String
7276
* ```
7377
*/
7478
fun asyncLambdaProcessor(init: AsyncLambdaMessageProcessorDslBuilder.() -> Unit) =
75-
com.jashmore.sqs.core.kotlin.dsl.processor.asyncLambdaProcessor(identifier, sqsAsyncClient, queueProperties, init)
79+
com.jashmore.sqs.core.kotlin.dsl.processor.asyncLambdaProcessor(
80+
identifier,
81+
sqsAsyncClient,
82+
queueProperties,
83+
init
84+
)
7685
}

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/container/BatchingMessageListenerContainerDslBuilder.kt

+6-1
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,12 @@ fun batchingMessageListener(
139139
queueUrl: String,
140140
init: BatchingMessageListenerContainerDslBuilder.() -> Unit
141141
): MessageListenerContainer {
142-
return batchingMessageListener(identifier, sqsAsyncClient, QueueProperties.builder().queueUrl(queueUrl).build(), init)
142+
return batchingMessageListener(
143+
identifier,
144+
sqsAsyncClient,
145+
QueueProperties.builder().queueUrl(queueUrl).build(),
146+
init
147+
)
143148
}
144149

145150
/**

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/container/CoreMessageListenerContainerDslBuilder.kt

+11-3
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,11 @@ import java.util.function.Supplier
3232
* [AbstractMessageListenerContainerDslBuilder] that will construct a [MessageListenerContainer] for usage in this container.
3333
*/
3434
@MessageListenerComponentDslMarker
35-
class CoreMessageListenerContainerDslBuilder(identifier: String, sqsAsyncClient: SqsAsyncClient, queueProperties: QueueProperties) :
35+
class CoreMessageListenerContainerDslBuilder(
36+
identifier: String,
37+
sqsAsyncClient: SqsAsyncClient,
38+
queueProperties: QueueProperties
39+
) :
3640
AbstractMessageListenerContainerDslBuilder(identifier, sqsAsyncClient, queueProperties) {
3741
var broker: MessageBrokerDslBuilder? = null
3842
var resolver: MessageResolverDslBuilder? = null
@@ -52,7 +56,9 @@ class CoreMessageListenerContainerDslBuilder(identifier: String, sqsAsyncClient:
5256
* }
5357
* ```
5458
*/
55-
fun concurrentBroker(init: ConcurrentMessageBrokerDslBuilder.() -> Unit) = com.jashmore.sqs.core.kotlin.dsl.broker.concurrentBroker(init)
59+
fun concurrentBroker(
60+
init: ConcurrentMessageBrokerDslBuilder.() -> Unit
61+
) = com.jashmore.sqs.core.kotlin.dsl.broker.concurrentBroker(init)
5662

5763
/**
5864
* Use the [GroupingMessageBroker] as the [MessageBroker] in this container.
@@ -67,7 +73,9 @@ class CoreMessageListenerContainerDslBuilder(identifier: String, sqsAsyncClient:
6773
* }
6874
* ```
6975
*/
70-
fun groupingBroker(init: GroupingMessageBrokerDslBuilder.() -> Unit) = com.jashmore.sqs.core.kotlin.dsl.broker.groupingBroker(init)
76+
fun groupingBroker(
77+
init: GroupingMessageBrokerDslBuilder.() -> Unit
78+
) = com.jashmore.sqs.core.kotlin.dsl.broker.groupingBroker(init)
7179

7280
/**
7381
* Use the [BatchingMessageRetriever] as the [MessageRetriever] for this container.

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/container/PrefetchingMessageListenerContainerDslBuilder.kt

+6-1
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,12 @@ fun prefetchingMessageListener(
138138
queueUrl: String,
139139
init: PrefetchingMessageListenerContainerDslBuilder.() -> Unit
140140
): MessageListenerContainer {
141-
return prefetchingMessageListener(identifier, sqsAsyncClient, QueueProperties.builder().queueUrl(queueUrl).build(), init)
141+
return prefetchingMessageListener(
142+
identifier,
143+
sqsAsyncClient,
144+
QueueProperties.builder().queueUrl(queueUrl).build(),
145+
init
146+
)
142147
}
143148

144149
/**

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/processor/AsyncLambdaMessageProcessorDslBuilder.kt

+6-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,12 @@ class AsyncLambdaMessageProcessorDslBuilder(
2323

2424
var decorators = mutableListOf<MessageProcessingDecorator>()
2525

26-
private var processorBuilder: () -> MessageProcessor = { throw RequiredFieldException("method", "LambdaMessageProcessor") }
26+
private var processorBuilder: () -> MessageProcessor = {
27+
throw RequiredFieldException(
28+
"method",
29+
"LambdaMessageProcessor"
30+
)
31+
}
2732

2833
fun method(func: (message: Message) -> CompletableFuture<*>) {
2934
processorBuilder = {

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/processor/CoreMessageProcessorDslBuilder.kt

+3-1
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,9 @@ class CoreMessageProcessorDslBuilder(
3030
*
3131
* If this is not supplied, a default [CoreArgumentResolverService] will be used which configures the core argument resolvers.
3232
*/
33-
var argumentResolverService: ArgumentResolverServiceDslBuilder = CoreArgumentResolverServiceDslBuilder(ObjectMapper())
33+
var argumentResolverService: ArgumentResolverServiceDslBuilder = CoreArgumentResolverServiceDslBuilder(
34+
ObjectMapper()
35+
)
3436

3537
/**
3638
* The object instance that will execute the message listener method.

‎extensions/core-kotlin-dsl/src/main/kotlin/com/jashmore/sqs/core/kotlin/dsl/processor/LambdaMessageProcessorDslBuilder.kt

+6-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,12 @@ class LambdaMessageProcessorDslBuilder(
2525
*/
2626
var decorators = listOf<MessageProcessingDecorator>()
2727

28-
private var processorBuilder: () -> MessageProcessor = { throw RequiredFieldException("method", "LambdaMessageProcessor") }
28+
private var processorBuilder: () -> MessageProcessor = {
29+
throw RequiredFieldException(
30+
"method",
31+
"LambdaMessageProcessor"
32+
)
33+
}
2934

3035
/**
3136
* Set the lambda as a method that just consumes the [Message].

0 commit comments

Comments
 (0)