3535import org .springframework .data .redis .connection .jedis .extension .JedisConnectionFactoryExtension ;
3636import org .springframework .data .redis .connection .lettuce .LettuceConnectionFactory ;
3737import org .springframework .data .redis .connection .lettuce .extension .LettuceConnectionFactoryExtension ;
38- import org .springframework .data .redis .connection .stream .*;
38+ import org .springframework .data .redis .connection .stream .Consumer ;
39+ import org .springframework .data .redis .connection .stream .MapRecord ;
40+ import org .springframework .data .redis .connection .stream .ObjectRecord ;
41+ import org .springframework .data .redis .connection .stream .PendingMessages ;
42+ import org .springframework .data .redis .connection .stream .PendingMessagesSummary ;
43+ import org .springframework .data .redis .connection .stream .ReadOffset ;
44+ import org .springframework .data .redis .connection .stream .RecordId ;
45+ import org .springframework .data .redis .connection .stream .StreamOffset ;
46+ import org .springframework .data .redis .connection .stream .StreamReadOptions ;
47+ import org .springframework .data .redis .connection .stream .StreamRecords ;
3948import org .springframework .data .redis .test .condition .EnabledOnCommand ;
4049import org .springframework .data .redis .test .condition .EnabledOnRedisDriver ;
4150import org .springframework .data .redis .test .condition .EnabledOnRedisVersion ;
@@ -65,7 +74,7 @@ public class DefaultStreamOperationsIntegrationTests<K, HK, HV> {
6574 private final StreamOperations <K , HK , HV > streamOps ;
6675
6776 public DefaultStreamOperationsIntegrationTests (RedisTemplate <K , ?> redisTemplate , ObjectFactory <K > keyFactory ,
68- ObjectFactory <?> objectFactory ) {
77+ ObjectFactory <?> objectFactory ) {
6978
7079 this .redisTemplate = redisTemplate ;
7180 this .connectionFactory = redisTemplate .getRequiredConnectionFactory ();
@@ -81,15 +90,15 @@ public static Collection<Object[]> testParams() {
8190 params .addAll (AbstractOperationsTestParams
8291 .testParams (JedisConnectionFactoryExtension .getConnectionFactory (RedisStanalone .class )));
8392
84- if (RedisDetector .isClusterAvailable ()) {
93+ if (RedisDetector .isClusterAvailable ()) {
8594 params .addAll (AbstractOperationsTestParams
8695 .testParams (JedisConnectionFactoryExtension .getConnectionFactory (RedisCluster .class )));
8796 }
8897
8998 params .addAll (AbstractOperationsTestParams
9099 .testParams (LettuceConnectionFactoryExtension .getConnectionFactory (RedisStanalone .class )));
91100
92- if (RedisDetector .isClusterAvailable ()) {
101+ if (RedisDetector .isClusterAvailable ()) {
93102 params .addAll (AbstractOperationsTestParams
94103 .testParams (LettuceConnectionFactoryExtension .getConnectionFactory (RedisCluster .class )));
95104 }
@@ -305,7 +314,8 @@ void readShouldReadSimpleMessage() {
305314 RecordId messageId1 = streamOps .add (StreamRecords .objectBacked (value ).withStreamKey (key ));
306315 streamOps .add (StreamRecords .objectBacked (value ).withStreamKey (key ));
307316
308- List <ObjectRecord <K , HV >> messages = streamOps .read ((Class <HV >) value .getClass (), StreamOffset .create (key , ReadOffset .from ("0-0" )));
317+ List <ObjectRecord <K , HV >> messages = streamOps .read ((Class <HV >) value .getClass (),
318+ StreamOffset .create (key , ReadOffset .from ("0-0" )));
309319
310320 assertThat (messages ).hasSize (2 );
311321
@@ -384,8 +394,7 @@ void pendingShouldReadMessageSummary() {
384394 RecordId messageId = streamOps .add (key , Collections .singletonMap (hashKey , value ));
385395 streamOps .createGroup (key , ReadOffset .from ("0-0" ), "my-group" );
386396
387- streamOps .read (Consumer .from ("my-group" , "my-consumer" ),
388- StreamOffset .create (key , ReadOffset .lastConsumed ()));
397+ streamOps .read (Consumer .from ("my-group" , "my-consumer" ), StreamOffset .create (key , ReadOffset .lastConsumed ()));
389398
390399 PendingMessagesSummary pending = streamOps .pending (key , "my-group" );
391400
@@ -403,8 +412,7 @@ void pendingShouldReadMessageDetails() {
403412 RecordId messageId = streamOps .add (key , Collections .singletonMap (hashKey , value ));
404413 streamOps .createGroup (key , ReadOffset .from ("0-0" ), "my-group" );
405414
406- streamOps .read (Consumer .from ("my-group" , "my-consumer" ),
407- StreamOffset .create (key , ReadOffset .lastConsumed ()));
415+ streamOps .read (Consumer .from ("my-group" , "my-consumer" ), StreamOffset .create (key , ReadOffset .lastConsumed ()));
408416
409417 PendingMessages pending = streamOps .pending (key , "my-group" , Range .unbounded (), 10L );
410418
0 commit comments