Skip to content

Commit 2d8caf7

Browse files
committed
refactor: run :spotlessApply to verify the build
1 parent 56250b1 commit 2d8caf7

File tree

5 files changed

+314
-239
lines changed

5 files changed

+314
-239
lines changed

redis-om-spring/src/main/java/com/redis/om/spring/RedisModulesConfiguration.java

Lines changed: 21 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,6 @@
88
import java.util.List;
99
import java.util.Set;
1010

11-
import com.redis.om.spring.ops.CommandListener;
12-
import com.redis.om.spring.ops.NoOpCommandListener;
1311
import org.apache.commons.lang3.ObjectUtils;
1412
import org.apache.commons.logging.Log;
1513
import org.apache.commons.logging.LogFactory;
@@ -44,6 +42,8 @@
4442
import com.redis.om.spring.client.RedisModulesClient;
4543
import com.redis.om.spring.indexing.RediSearchIndexer;
4644
import com.redis.om.spring.mapping.RedisEnhancedMappingContext;
45+
import com.redis.om.spring.ops.CommandListener;
46+
import com.redis.om.spring.ops.NoOpCommandListener;
4747
import com.redis.om.spring.ops.RedisModulesOperations;
4848
import com.redis.om.spring.ops.json.JSONOperations;
4949
import com.redis.om.spring.ops.pds.BloomOperations;
@@ -201,9 +201,9 @@ RedisModulesClient redisModulesClient( //
201201
* including JSON, Search, Bloom filters, and other probabilistic data structures.
202202
* It serves as the central operations hub for Redis OM Spring functionality.
203203
*
204-
* @param rmc the Redis modules client for low-level access
205-
* @param template the string Redis template for basic operations
206-
* @param gsonBuilder the Gson builder for JSON serialization
204+
* @param rmc the Redis modules client for low-level access
205+
* @param template the string Redis template for basic operations
206+
* @param gsonBuilder the Gson builder for JSON serialization
207207
* @param commandListener a command listener for monitoring Redis commands
208208
* @return the Redis modules operations instance
209209
*/
@@ -222,23 +222,22 @@ RedisModulesOperations<?> redisModulesOperations( //
222222
return new RedisModulesOperations<>(rmc, template, gsonBuilder, commandListener);
223223
}
224224

225-
/**
226-
* Provides a default implementation of the CommandListener bean.
227-
* <p>
228-
* This method creates a no-operation (NoOp) implementation of the CommandListener interface.
229-
* It is used as a fallback when no other CommandListener bean is defined in the application context.
230-
* <p>
231-
* The {@code @Fallback} annotation ensures that this bean is only used when no other
232-
* CommandListener bean is available, allowing developers to override it with a custom implementation if needed.
233-
*
234-
* @return a NoOpCommandListener instance, which performs no operations.
235-
*/
236-
@Bean
237-
@Fallback
238-
public CommandListener commandListener() {
239-
return new NoOpCommandListener();
240-
}
241-
225+
/**
226+
* Provides a default implementation of the CommandListener bean.
227+
* <p>
228+
* This method creates a no-operation (NoOp) implementation of the CommandListener interface.
229+
* It is used as a fallback when no other CommandListener bean is defined in the application context.
230+
* <p>
231+
* The {@code @Fallback} annotation ensures that this bean is only used when no other
232+
* CommandListener bean is available, allowing developers to override it with a custom implementation if needed.
233+
*
234+
* @return a NoOpCommandListener instance, which performs no operations.
235+
*/
236+
@Bean
237+
@Fallback
238+
public CommandListener commandListener() {
239+
return new NoOpCommandListener();
240+
}
242241

243242
/**
244243
* Creates the JSON operations bean for RedisJSON commands.
Lines changed: 125 additions & 50 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,12 @@
11
package com.redis.om.spring.ops;
22

3+
import java.util.List;
4+
import java.util.Map;
5+
import java.util.Set;
6+
37
import com.redis.om.spring.autocomplete.Suggestion;
48
import com.redis.om.spring.repository.query.autocomplete.AutoCompleteOptions;
9+
510
import redis.clients.jedis.search.FTCreateParams;
611
import redis.clients.jedis.search.FTSearchParams;
712
import redis.clients.jedis.search.IndexOptions;
@@ -12,79 +17,149 @@
1217
import redis.clients.jedis.search.aggr.AggregationBuilder;
1318
import redis.clients.jedis.search.aggr.AggregationResult;
1419
import redis.clients.jedis.search.schemafields.SchemaField;
15-
import java.util.List;
16-
import java.util.Map;
17-
import java.util.Set;
1820

1921
public interface CommandListener {
20-
default void searchStarted(String indexName, Query q, FTSearchParams params) {}
21-
default void searchFinished(String indexName, Query q, FTSearchParams params, SearchResult searchResult){}
22+
default void searchStarted(String indexName, Query q, FTSearchParams params) {
23+
}
24+
25+
default void searchFinished(String indexName, Query q, FTSearchParams params, SearchResult searchResult) {
26+
}
27+
28+
default void createIndexStarted(String indexName, FTCreateParams params, List<SchemaField> fields, Schema schema,
29+
IndexOptions options) {
30+
}
31+
32+
default void createIndexFinished(String indexName, FTCreateParams params, List<SchemaField> fields, Schema schema,
33+
IndexOptions options, String result) {
34+
}
35+
36+
default void aggregateStarted(String indexName, AggregationBuilder q) {
37+
}
38+
39+
default void aggregateFinished(String indexName, AggregationBuilder q, AggregationResult result) {
40+
}
41+
42+
default void cursorDeleteStarted(String string, long cursorId) {
43+
}
44+
45+
default void cursorDeleteFinished(String string, long cursorId, String result) {
46+
}
47+
48+
default void cursorReadStarted(String string, long cursorId, int count) {
49+
}
50+
51+
default void cursorReadFinished(String string, long cursorId, int count, AggregationResult aggregationResult) {
52+
}
53+
54+
default void explainStarted(String string, Query q) {
55+
}
56+
57+
default void explainFinished(String string, Query q, String s) {
58+
}
59+
60+
default void infoStarted(String string) {
61+
}
62+
63+
default void infoFinished(String string, Map<String, Object> stringObjectMap) {
64+
}
65+
66+
default void dropIndexStarted(String string) {
67+
}
68+
69+
default void dropIndexFinished(String string, String result) {
70+
}
71+
72+
default void dropIndexAndDocumentsStarted(String string) {
73+
}
74+
75+
default void dropIndexAndDocumentsFinished(String string, String result) {
76+
}
77+
78+
default void addSuggestionStarted(String string, String key, String suggestion, double score) {
79+
}
80+
81+
default void addSuggestionFinished(String string, String key, String suggestion, double score, long result) {
82+
}
83+
84+
default void getSuggestionStarted(String string, String key, String prefix, AutoCompleteOptions options) {
85+
}
86+
87+
default void getSuggestionFinished(String string, String key, String prefix, AutoCompleteOptions options,
88+
List<Suggestion> list) {
89+
}
90+
91+
default void deleteSuggestionStarted(String string, String key, String entry) {
92+
}
93+
94+
default void deleteSuggestionFinished(String string, String key, String entry, boolean result) {
95+
}
2296

23-
default void createIndexStarted(String indexName, FTCreateParams params, List<SchemaField> fields, Schema schema, IndexOptions options){}
24-
default void createIndexFinished(String indexName, FTCreateParams params, List<SchemaField> fields, Schema schema, IndexOptions options, String result){}
97+
default void getSuggestionLengthStarted(String string, String key) {
98+
}
2599

26-
default void aggregateStarted(String indexName, AggregationBuilder q){}
27-
default void aggregateFinished(String indexName, AggregationBuilder q, AggregationResult result){}
100+
default void getSuggestionLengthFinished(String string, String key, long result) {
101+
}
28102

29-
default void cursorDeleteStarted(String string, long cursorId){}
30-
default void cursorDeleteFinished(String string, long cursorId, String result){}
103+
default void alterIndexStarted(String string, SchemaField[] fields) {
104+
}
31105

32-
default void cursorReadStarted(String string, long cursorId, int count){}
33-
default void cursorReadFinished(String string, long cursorId, int count, AggregationResult aggregationResult){}
106+
default void alterIndexFinished(String string, SchemaField[] fields, String result) {
107+
}
34108

35-
default void explainStarted(String string, Query q){}
36-
default void explainFinished(String string, Query q, String s){}
109+
default void setConfigStarted(String string, String option, String value) {
110+
}
37111

38-
default void infoStarted(String string){}
39-
default void infoFinished(String string, Map<String, Object> stringObjectMap){}
112+
default void setConfigFinished(String string, String option, String value, String result) {
113+
}
40114

41-
default void dropIndexStarted(String string){}
42-
default void dropIndexFinished(String string, String result){}
115+
default void getConfigStarted(String string, String option) {
116+
}
43117

44-
default void dropIndexAndDocumentsStarted(String string){}
45-
default void dropIndexAndDocumentsFinished(String string, String result){}
118+
default void getConfigFinished(String string, String option, Map<String, Object> result) {
119+
}
46120

47-
default void addSuggestionStarted(String string, String key, String suggestion, double score){}
48-
default void addSuggestionFinished(String string, String key, String suggestion, double score, long result){}
121+
default void getIndexConfigStarted(String string, String option) {
122+
}
49123

50-
default void getSuggestionStarted(String string, String key, String prefix, AutoCompleteOptions options){}
51-
default void getSuggestionFinished(String string, String key, String prefix, AutoCompleteOptions options, List<Suggestion> list){}
124+
default void getIndexConfigFinished(String string, String option, Map<String, Object> result) {
125+
}
52126

53-
default void deleteSuggestionStarted(String string, String key, String entry){}
54-
default void deleteSuggestionFinished(String string, String key, String entry, boolean result){}
127+
default void addAliasStarted(String string, String name) {
128+
}
55129

56-
default void getSuggestionLengthStarted(String string, String key){}
57-
default void getSuggestionLengthFinished(String string, String key, long result){}
130+
default void addAliasFinished(String string, String name, String result) {
131+
}
58132

59-
default void alterIndexStarted(String string, SchemaField[] fields){}
60-
default void alterIndexFinished(String string, SchemaField[] fields, String result){}
133+
default void updateAliasStarted(String string, String name) {
134+
}
61135

62-
default void setConfigStarted(String string, String option, String value){}
63-
default void setConfigFinished(String string, String option, String value, String result){}
136+
default void updateAliasFinished(String string, String name, String result) {
137+
}
64138

65-
default void getConfigStarted(String string, String option){}
66-
default void getConfigFinished(String string, String option, Map<String, Object> result){}
139+
default void deleteAliasStarted(String string, String name) {
140+
}
67141

68-
default void getIndexConfigStarted(String string, String option){}
69-
default void getIndexConfigFinished(String string, String option, Map<String, Object> result){}
142+
default void deleteAliasFinished(String string, String name, String result) {
143+
}
70144

71-
default void addAliasStarted(String string, String name){}
72-
default void addAliasFinished(String string, String name, String result){}
145+
default void updateSynonymStarted(String string, String synonymGroupId, String[] terms) {
146+
}
73147

74-
default void updateAliasStarted(String string, String name){}
75-
default void updateAliasFinished(String string, String name, String result){}
148+
default void updateSynonymFinished(String string, String synonymGroupId, String[] terms, String result) {
149+
}
76150

77-
default void deleteAliasStarted(String string, String name){}
78-
default void deleteAliasFinished(String string, String name, String result){}
151+
default void dumpSynonymStarted(String string) {
152+
}
79153

80-
default void updateSynonymStarted(String string, String synonymGroupId, String[] terms){}
81-
default void updateSynonymFinished(String string, String synonymGroupId, String[] terms, String result){}
154+
default void dumpSynonymFinished(String string, Map<String, List<String>> result) {
155+
}
82156

83-
default void dumpSynonymStarted(String string){}
84-
default void dumpSynonymFinished(String string, Map<String, List<String>> result){}
157+
default void tagValsStarted(String string, String field) {
158+
}
85159

86-
default void tagValsStarted(String string, String field){}
87-
default void tagValsFinished(String string, String field, Set<String> result){}
160+
default void tagValsFinished(String string, String field, Set<String> result) {
161+
}
88162

89-
default void commandFailed(SearchProtocol.SearchCommand command, String indexName, Throwable t){}
163+
default void commandFailed(SearchProtocol.SearchCommand command, String indexName, Throwable t) {
164+
}
90165
}
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
package com.redis.om.spring.ops;
22

3-
public class NoOpCommandListener implements CommandListener {
3+
public class NoOpCommandListener implements CommandListener {
44
}

redis-om-spring/src/main/java/com/redis/om/spring/ops/RedisModulesOperations.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@
2222
* and provides typed access to module-specific operations through the {@code opsFor*} methods.
2323
* </p>
2424
*
25-
* @param <K> the type of keys used in Redis operations
26-
* @param client the Redis modules client for executing commands
27-
* @param template the Spring Data Redis template for additional Redis operations
28-
* @param gsonBuilder the Gson builder for JSON serialization/deserialization configuration
25+
* @param <K> the type of keys used in Redis operations
26+
* @param client the Redis modules client for executing commands
27+
* @param template the Spring Data Redis template for additional Redis operations
28+
* @param gsonBuilder the Gson builder for JSON serialization/deserialization configuration
2929
* @param commandListener A command listener for monitoring Redis commands
3030
*
3131
* @author Redis OM Spring Team

0 commit comments

Comments
 (0)