@@ -88,32 +88,6 @@ public interface MultiKeyJedisClusterCommands {
8888
8989 Set <String > keys (String pattern );
9090
91- /**
92- * XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
93- *
94- * @param count
95- * @param block
96- * @param streams
97- * @return
98- */
99- List <Map .Entry <String , List <StreamEntry >>> xread (int count , long block , Map .Entry <String , StreamEntryID >... streams );
100-
101- List <Map .Entry <String , List <StreamEntry >>> xread (XReadParams xReadParams , Map <String , StreamEntryID > streams );
102-
103- /**
104- * XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
105- *
106- * @param groupname
107- * @param consumer
108- * @param count
109- * @param block
110- * @param streams
111- * @return
112- */
113- List <Map .Entry <String , List <StreamEntry >>> xreadGroup (String groupname , String consumer , int count , long block , boolean noAck , Map .Entry <String , StreamEntryID >... streams );
114-
115- List <Map .Entry <String , List <StreamEntry >>> xreadGroup (String groupname , String consumer , XReadGroupParams xReadGroupParams , Map <String , StreamEntryID > streams );
116-
11791 Long georadiusStore (String key , double longitude , double latitude , double radius ,
11892 GeoUnit unit , GeoRadiusParam param , GeoRadiusStoreParam storeParam );
11993
@@ -130,6 +104,8 @@ Long georadiusByMemberStore(String key, String member, double radius, GeoUnit un
130104 */
131105 List <Map .Entry <String , List <StreamEntry >>> xread (int count , long block , Map .Entry <String , StreamEntryID >... streams );
132106
107+ List <Map .Entry <String , List <StreamEntry >>> xread (XReadParams xReadParams , Map <String , StreamEntryID > streams );
108+
133109 /**
134110 * XREAD [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] ID [ID ...]
135111 *
@@ -143,4 +119,6 @@ Long georadiusByMemberStore(String key, String member, double radius, GeoUnit un
143119 */
144120 List <Map .Entry <String , List <StreamEntry >>> xreadGroup (String groupname , String consumer , int count , long block , boolean noAck , Map .Entry <String , StreamEntryID >... streams );
145121
122+ List <Map .Entry <String , List <StreamEntry >>> xreadGroup (String groupname , String consumer , XReadGroupParams xReadGroupParams , Map <String , StreamEntryID > streams );
123+
146124}
0 commit comments