Programming Challenge redislabs-training#6 optimization

ThiernoAmirouDiallo · Nov 14, 2022 · 3390941 · 3390941
1 parent 51f4719
commit 3390941
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImpl.java b/src/main/java/com/redislabs/university/RU102J/dao/FeedDaoRedisImpl.java
@@ -28,8 +28,8 @@ public void insert( MeterReading meterReading ) {
 		try ( Jedis jedis = jedisPool.getResource() ) {
 			Pipeline pipeline = jedis.pipelined();
 
-			pipeline.xadd( RedisSchema.getGlobalFeedKey(), StreamEntryID.NEW_ENTRY, meterReading.toMap() );
-			pipeline.xadd( RedisSchema.getFeedKey( meterReading.getSiteId() ), StreamEntryID.NEW_ENTRY, meterReading.toMap() );
+			pipeline.xadd( RedisSchema.getGlobalFeedKey(), StreamEntryID.NEW_ENTRY, meterReading.toMap(), globalMaxFeedLength, true );
+			pipeline.xadd( RedisSchema.getFeedKey( meterReading.getSiteId() ), StreamEntryID.NEW_ENTRY, meterReading.toMap(), siteMaxFeedLength, true );
 
 			pipeline.sync();
 		}