SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix race in KafkaBinderTests

Browse Source 
`testDlqWithNativeSerializationEnabledOnDlqProducer`
This commit is contained in:
Gary Russell
2019-10-03 10:35:05 -04:00
parent 65dd706a6a
commit 21fe9c75c5
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
View File

@@ -36,6 +36,7 @@ import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.IntStream;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.CreateTopicsResult;
@@ -3429,7 +3430,7 @@ public class KafkaBinderTests extends
private final class FailingInvocationCountingMessageHandler
implements MessageHandler {
private int invocationCount;
private volatile int invocationCount;
private final LinkedHashMap<Long, Message<?>> receivedMessages = new LinkedHashMap<>();