17
17
18
18
import static org .assertj .core .api .Assertions .*;
19
19
20
+ import java .io .Serializable ;
20
21
import java .util .Collections ;
21
22
import java .util .Map ;
22
23
23
24
import org .junit .Test ;
25
+
24
26
import org .springframework .data .redis .connection .stream .ByteRecord ;
25
27
import org .springframework .data .redis .connection .stream .MapRecord ;
26
28
import org .springframework .data .redis .connection .stream .ObjectRecord ;
31
33
import org .springframework .data .redis .serializer .Jackson2JsonRedisSerializer ;
32
34
import org .springframework .data .redis .serializer .RedisSerializer ;
33
35
34
- import java .io .Serializable ;
35
-
36
36
/**
37
+ * Unit tests for {@link StreamRecords}.
38
+ *
37
39
* @author Christoph Strobl
38
40
* @author Romain Beghi
39
41
*/
@@ -45,12 +47,13 @@ public class StreamRecordsUnitTests {
45
47
static final String STRING_VAL = "string-val" ;
46
48
static final DummyObject OBJECT_VAL = new DummyObject ();
47
49
48
- static final Jackson2JsonRedisSerializer <DummyObject > JSON_REDIS_SERIALIZER = new Jackson2JsonRedisSerializer <>(DummyObject .class );
50
+ static final Jackson2JsonRedisSerializer <DummyObject > JSON_REDIS_SERIALIZER = new Jackson2JsonRedisSerializer <>(
51
+ DummyObject .class );
49
52
50
53
static final byte [] SERIALIZED_STRING_VAL = RedisSerializer .string ().serialize (STRING_VAL );
51
54
static final byte [] SERIALIZED_STRING_MAP_KEY = RedisSerializer .string ().serialize (STRING_MAP_KEY );
52
55
static final byte [] SERIALIZED_STRING_STREAM_KEY = RedisSerializer .string ().serialize (STRING_STREAM_KEY );
53
- static final byte [] SERIALIZED_OBJECT_VAL = JSON_REDIS_SERIALIZER .serialize (OBJECT_VAL );
56
+ static final byte [] SERIALIZED_JSON_OBJECT_VAL = JSON_REDIS_SERIALIZER .serialize (OBJECT_VAL );
54
57
55
58
private static class DummyObject implements Serializable {
56
59
private final Integer dummyId = 1 ;
@@ -111,7 +114,7 @@ public void serializeMapRecordObjectAsHashValue() {
111
114
assertThat (target .getId ()).isEqualTo (RECORD_ID );
112
115
assertThat (target .getStream ()).isEqualTo (SERIALIZED_STRING_STREAM_KEY );
113
116
assertThat (target .getValue ().keySet ().iterator ().next ()).isEqualTo (SERIALIZED_STRING_MAP_KEY );
114
- assertThat (target .getValue ().values ().iterator ().next ()).isEqualTo (SERIALIZED_OBJECT_VAL );
117
+ assertThat (target .getValue ().values ().iterator ().next ()).isEqualTo (SERIALIZED_JSON_OBJECT_VAL );
115
118
}
116
119
117
120
@ Test // DATAREDIS-864
0 commit comments