@@ -73,7 +73,7 @@ public class LruNodeClient extends NodeClient {
73
73
logger .debug ("index" );
74
74
lru .ensureOpen (request .index (),new LruIndexManager .IndexOperation () {
75
75
public void perform () {
76
- LruClient .super .index (request ,listener );
76
+ LruNodeClient .super .index (request ,listener );
77
77
}
78
78
});
79
79
@@ -83,7 +83,7 @@ public void perform() {
83
83
logger .debug ("delete" );
84
84
return (ActionFuture <DeleteResponse >)lru .ensureOpen (request .index (), new LruIndexManager .AsyncIndexOperation () {
85
85
public ActionFuture <DeleteResponse > perform () {
86
- return LruClient .super .delete (request );
86
+ return LruNodeClient .super .delete (request );
87
87
}
88
88
});
89
89
}
@@ -92,7 +92,7 @@ public ActionFuture<DeleteResponse> perform() {
92
92
logger .debug ("delete" );
93
93
lru .ensureOpen (request .index (),new LruIndexManager .IndexOperation () {
94
94
public void perform () {
95
- LruClient .super .delete (request , listener );
95
+ LruNodeClient .super .delete (request , listener );
96
96
}
97
97
});
98
98
}
@@ -101,7 +101,7 @@ public void perform() {
101
101
logger .debug ("bulk" );
102
102
return (ActionFuture <BulkResponse >)lru .ensureOpen (getIndices (request ), new LruIndexManager .AsyncIndexOperation () {
103
103
public ActionFuture <BulkResponse > perform () {
104
- return LruClient .super .bulk (request );
104
+ return LruNodeClient .super .bulk (request );
105
105
}
106
106
});
107
107
@@ -111,7 +111,7 @@ public ActionFuture<BulkResponse> perform() {
111
111
logger .debug ("bulk" );
112
112
lru .ensureOpen (getIndices (request ),new LruIndexManager .IndexOperation () {
113
113
public void perform () {
114
- LruClient .super .bulk (request ,listener );
114
+ LruNodeClient .super .bulk (request ,listener );
115
115
}
116
116
});
117
117
@@ -121,7 +121,7 @@ public void perform() {
121
121
logger .debug ("deleteByQuery" );
122
122
return (ActionFuture <DeleteByQueryResponse >)lru .ensureOpen (request .indices (), new LruIndexManager .AsyncIndexOperation () {
123
123
public ActionFuture <DeleteByQueryResponse > perform () {
124
- return LruClient .super .deleteByQuery (request );
124
+ return LruNodeClient .super .deleteByQuery (request );
125
125
}
126
126
});
127
127
}
@@ -130,7 +130,7 @@ public ActionFuture<DeleteByQueryResponse> perform() {
130
130
logger .debug ("deleteByQuery" );
131
131
lru .ensureOpen (request .indices (),new LruIndexManager .IndexOperation () {
132
132
public void perform () {
133
- LruClient .super .deleteByQuery (request ,listener );
133
+ LruNodeClient .super .deleteByQuery (request ,listener );
134
134
}
135
135
});
136
136
}
@@ -139,7 +139,7 @@ public void perform() {
139
139
logger .debug ("get" );
140
140
return (ActionFuture <GetResponse >)lru .ensureOpen (request .index (), new LruIndexManager .AsyncIndexOperation () {
141
141
public ActionFuture <GetResponse > perform () {
142
- return LruClient .super .get (request );
142
+ return LruNodeClient .super .get (request );
143
143
}
144
144
});
145
145
}
@@ -148,7 +148,7 @@ public ActionFuture<GetResponse> perform() {
148
148
logger .debug ("get" );
149
149
lru .ensureOpen (request .index (),new LruIndexManager .IndexOperation () {
150
150
public void perform () {
151
- LruClient .super .get (request , listener );
151
+ LruNodeClient .super .get (request , listener );
152
152
}
153
153
});
154
154
@@ -158,7 +158,7 @@ public void perform() {
158
158
logger .debug ("count" );
159
159
return (ActionFuture <CountResponse >)lru .ensureOpen (request .indices (), new LruIndexManager .AsyncIndexOperation () {
160
160
public ActionFuture <CountResponse > perform () {
161
- return LruClient .super .count (request );
161
+ return LruNodeClient .super .count (request );
162
162
}
163
163
});
164
164
}
@@ -167,7 +167,7 @@ public ActionFuture<CountResponse> perform() {
167
167
logger .debug ("count" );
168
168
lru .ensureOpen (request .indices (),new LruIndexManager .IndexOperation () {
169
169
public void perform () {
170
- LruClient .super .count (request , listener );
170
+ LruNodeClient .super .count (request , listener );
171
171
}
172
172
});
173
173
@@ -177,7 +177,7 @@ public void perform() {
177
177
logger .debug ("search" );
178
178
return (ActionFuture <SearchResponse >)lru .ensureOpen (request .indices (), new LruIndexManager .AsyncIndexOperation () {
179
179
public ActionFuture <SearchResponse > perform () {
180
- return LruClient .super .search (request );
180
+ return LruNodeClient .super .search (request );
181
181
}
182
182
});
183
183
}
@@ -186,7 +186,7 @@ public ActionFuture<SearchResponse> perform() {
186
186
logger .debug ("search" );
187
187
lru .ensureOpen (request .indices (),new LruIndexManager .IndexOperation () {
188
188
public void perform () {
189
- LruClient .super .search (request , listener );
189
+ LruNodeClient .super .search (request , listener );
190
190
}
191
191
});
192
192
}
@@ -205,7 +205,7 @@ public void perform() {
205
205
logger .debug ("moreLikeThis" );
206
206
return (ActionFuture <SearchResponse >)lru .ensureOpen (request .index (), new LruIndexManager .AsyncIndexOperation () {
207
207
public ActionFuture <SearchResponse > perform () {
208
- return LruClient .super .moreLikeThis (request );
208
+ return LruNodeClient .super .moreLikeThis (request );
209
209
}
210
210
});
211
211
}
@@ -214,7 +214,7 @@ public ActionFuture<SearchResponse> perform() {
214
214
logger .debug ("moreLikeThis" );
215
215
lru .ensureOpen (request .index (),new LruIndexManager .IndexOperation () {
216
216
public void perform () {
217
- LruClient .super .moreLikeThis (request , listener );
217
+ LruNodeClient .super .moreLikeThis (request , listener );
218
218
}
219
219
});
220
220
}
0 commit comments