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

DATAREDIS-1172 - Polishing.

Browse Source 
Suppress rawtypes/unchecked warnings. Use static imports for mockito.

Original pull request: #542.
This commit is contained in:
Mark Paluch
2020-07-15 11:57:54 +02:00
parent b23e972b55
commit 48e2360595
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/org/springframework/data/redis/stream/StreamReceiverIntegrationTests.java
View File

@@ -18,6 +18,7 @@ package org.springframework.data.redis.stream;
import static org.assertj.core.api.Assertions.*;
import static org.junit.Assume.*;
import static org.mockito.ArgumentMatchers.*;
import static org.mockito.Mockito.*;
import lombok.AllArgsConstructor;
import lombok.Data;
@@ -32,7 +33,7 @@ import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.mockito.Mockito;
import org.springframework.data.redis.ConnectionFactoryTracker;
import org.springframework.data.redis.RedisSystemException;
import org.springframework.data.redis.RedisVersionUtils;
@@ -175,8 +176,8 @@ public class StreamReceiverIntegrationTests {
@Test // DATAREDIS-1172
public void shouldReceiveCustomHashValueRecords() {
SerializationPair<Integer> serializationPair = Mockito.mock(SerializationPair.class);
Mockito.when(serializationPair.read(any(ByteBuffer.class))).thenReturn(345920);
SerializationPair<Integer> serializationPair = mock(SerializationPair.class);
when(serializationPair.read(any(ByteBuffer.class))).thenReturn(345920);
StreamReceiverOptions<String, MapRecord<String, String, Integer>> receiverOptions = StreamReceiverOptions.builder()
.<String, Integer>hashValueSerializer(serializationPair).build();
@@ -227,7 +228,6 @@ public class StreamReceiverIntegrationTests {
}).consumeNextWith(it -> {
assertThat(it.getStream()).isEqualTo("my-stream");
// assertThat(it.getValue()).containsEntry("key", "value3");
}) //
.thenCancel() //
.verify(Duration.ofSeconds(5));