Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

More JVM memory for Gradle

Browse Source 
* Fix race condition in the `KafkaOutboundAdapterParserTests`
This commit is contained in:
Artem Bilan
2021-02-23 11:28:04 -05:00
parent ba3c9bf00f
commit 9c686ddcb7
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gradle.properties
View File

@@ -1,5 +1,5 @@
version=5.5.0-SNAPSHOT version=5.5.0-SNAPSHOT
org.gradle.jvmargs=-Xmx2g -Dfile.encoding=UTF-8 org.gradle.jvmargs=-Xms512m -Xmx4g -XX:MaxPermSize=1024m -XX:MaxMetaspaceSize=1g -Dkotlin.daemon.jvm.options="-Xmx1g" -Dfile.encoding=UTF-8
org.gradle.caching=true org.gradle.caching=true
org.gradle.parallel=true org.gradle.parallel=true
kotlin.stdlib.default.dependency=false kotlin.stdlib.default.dependency=false

6
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java
View File

@@ -1,5 +1,5 @@
/* /*
* Copyright 2013-2020 the original author or authors. * Copyright 2013-2021 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@@ -101,7 +101,7 @@ class KafkaOutboundAdapterParserTests {
@Test @Test
void testSyncMode() { void testSyncMode() {
MockProducer<Integer, String> mockProducer = MockProducer<Integer, String> mockProducer =
new MockProducer<Integer, String>(false, new IntegerSerializer(), new StringSerializer()) { new MockProducer<>(false, new IntegerSerializer(), new StringSerializer()) {
@Override @Override
public void close(Duration timeout) { public void close(Duration timeout) {
@@ -121,7 +121,7 @@ class KafkaOutboundAdapterParserTests {
handler.afterPropertiesSet(); handler.afterPropertiesSet();
handler.setSync(true); handler.setSync(true);
handler.setSendTimeout(10); handler.setSendTimeout(10_000);
handler.setTimeoutBuffer(200); handler.setTimeoutBuffer(200);
handler.setTopicExpression(new LiteralExpression("foo")); handler.setTopicExpression(new LiteralExpression("foo"));