@@ -252,12 +252,15 @@ public void search(String base, String filter, int searchScope, boolean returnin
252
252
@ Override
253
253
public void search (final Name base , final String filter , final SearchControls controls ,
254
254
NameClassPairCallbackHandler handler ) {
255
-
255
+ SearchExecutor se = (ctx ) -> {
256
+ LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
257
+ return ctx .search (base , filter , controls );
258
+ };
256
259
// Create a SearchExecutor to perform the search.
257
260
if (handler instanceof ContextMapperCallbackHandler ) {
258
261
assureReturnObjFlagSet (controls );
259
262
}
260
- search (searchExecutorWithLogging ( base , filter , controls ) , handler );
263
+ search (se , handler );
261
264
}
262
265
263
266
/**
@@ -266,12 +269,15 @@ public void search(final Name base, final String filter, final SearchControls co
266
269
@ Override
267
270
public void search (final String base , final String filter , final SearchControls controls ,
268
271
NameClassPairCallbackHandler handler ) {
269
-
272
+ SearchExecutor se = (ctx ) -> {
273
+ LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
274
+ return ctx .search (base , filter , controls );
275
+ };
270
276
// Create a SearchExecutor to perform the search.
271
277
if (handler instanceof ContextMapperCallbackHandler ) {
272
278
assureReturnObjFlagSet (controls );
273
279
}
274
- search (searchExecutorWithLogging ( base , filter , controls ) , handler );
280
+ search (se , handler );
275
281
}
276
282
277
283
/**
@@ -280,12 +286,15 @@ public void search(final String base, final String filter, final SearchControls
280
286
@ Override
281
287
public void search (final Name base , final String filter , final SearchControls controls ,
282
288
NameClassPairCallbackHandler handler , DirContextProcessor processor ) {
283
-
289
+ SearchExecutor se = (ctx ) -> {
290
+ LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
291
+ return ctx .search (base , filter , controls );
292
+ };
284
293
// Create a SearchExecutor to perform the search.
285
294
if (handler instanceof ContextMapperCallbackHandler ) {
286
295
assureReturnObjFlagSet (controls );
287
296
}
288
- search (searchExecutorWithLogging ( base , filter , controls ) , handler , processor );
297
+ search (se , handler , processor );
289
298
}
290
299
291
300
/**
@@ -294,12 +303,15 @@ public void search(final Name base, final String filter, final SearchControls co
294
303
@ Override
295
304
public void search (final String base , final String filter , final SearchControls controls ,
296
305
NameClassPairCallbackHandler handler , DirContextProcessor processor ) {
297
-
306
+ SearchExecutor se = (ctx ) -> {
307
+ LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
308
+ return ctx .search (base , filter , controls );
309
+ };
298
310
// Create a SearchExecutor to perform the search.
299
311
if (handler instanceof ContextMapperCallbackHandler ) {
300
312
assureReturnObjFlagSet (controls );
301
313
}
302
- search (searchExecutorWithLogging ( base , filter , controls ) , handler , processor );
314
+ search (se , handler , processor );
303
315
}
304
316
305
317
/**
@@ -1552,7 +1564,10 @@ <T> Stream<T> searchForStream(LdapQuery query, Function<SearchResult, T> mapper)
1552
1564
1553
1565
assureReturnObjFlagSet (searchControls );
1554
1566
1555
- NamingEnumeration <SearchResult > results = unchecked (searchSupplier (ctx , base , encodedFilter , searchControls ));
1567
+ NamingEnumeration <SearchResult > results = unchecked (() -> {
1568
+ LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
1569
+ return ctx .search (base , encodedFilter , searchControls );
1570
+ });
1556
1571
if (results == null ) {
1557
1572
return Stream .empty ();
1558
1573
}
@@ -1781,38 +1796,6 @@ public <T> Stream<T> findForStream(LdapQuery query, Class<T> clazz) {
1781
1796
return searchForStream (builder .filter (includeClass ), contextMapper );
1782
1797
}
1783
1798
1784
- private SearchExecutor searchExecutorWithLogging (final Name base , final String filter ,
1785
- final SearchControls controls ) {
1786
- return ctx -> {
1787
- if (LOG .isDebugEnabled ()) {
1788
- LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
1789
- }
1790
- return ctx .search (base , filter , controls );
1791
- };
1792
- }
1793
-
1794
- private SearchExecutor searchExecutorWithLogging (final String base , final String filter ,
1795
- final SearchControls controls ) {
1796
- return ctx -> {
1797
- if (LOG .isDebugEnabled ()) {
1798
- LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
1799
- }
1800
- return ctx .search (base , filter , controls );
1801
- };
1802
- }
1803
-
1804
- private CheckedSupplier <NamingEnumeration <SearchResult >> searchSupplier (final DirContext ctx ,
1805
- final Name base ,
1806
- final String filter ,
1807
- final SearchControls controls ) {
1808
- return () -> {
1809
- if (LOG .isDebugEnabled ()) {
1810
- LOG .debug ("Executing search with base [{}] and filter [{}]" , base , filter );
1811
- }
1812
- return ctx .search (base , filter , controls );
1813
- };
1814
- }
1815
-
1816
1799
private <T > T unchecked (CheckedSupplier <T > supplier ) {
1817
1800
try {
1818
1801
return supplier .get ();
0 commit comments