Revision 41626
Added by Nikon Gasparis about 8 years ago
| MemoryThreadValidator.java | ||
|---|---|---|
| 41 | 41 |
* @author Nikon Gasparis |
| 42 | 42 |
* @see ExecutorService |
| 43 | 43 |
*/ |
| 44 |
|
|
| 45 |
@Deprecated |
|
| 44 | 46 |
public class MemoryThreadValidator implements Validator {
|
| 45 | 47 |
|
| 46 | 48 |
private CacheManager cacheManager; |
| ... | ... | |
| 196 | 198 |
|
| 197 | 199 |
CrisListener crisListener = listenersManager.createCrisListener(); |
| 198 | 200 |
crisListener.setWorkersFirstPhase(rulesPerEntity.keySet().size()); |
| 199 |
crisListener.setExecutor(executor); |
|
| 201 |
//TODO remove as soon as spring validator works ok |
|
| 202 |
// crisListener.setExecutor(executor); |
|
| 200 | 203 |
crisListener.setProvider(prv); |
| 201 | 204 |
crisListener.setWorkers(rulesPerEntity.keySet().size() + rulesPerEntityRef.keySet().size()); |
| 202 | 205 |
if (!rulesPerEntityRef.isEmpty()) {
|
| ... | ... | |
| 225 | 228 |
prv.setConfiguration(props); |
| 226 | 229 |
submittersForReferential.add(new ThreadExecutorSubmitter(job.id, entry.getValue(), entry.getKey(), prv, mainListener, taskExecutor, timeout, generalTimeout, listeners)); |
| 227 | 230 |
} |
| 228 |
crisListener.setSubmittersForReferential(submittersForReferential); |
|
| 231 |
//TODO remove as soon as spring validator works ok |
|
| 232 |
// crisListener.setSubmittersForReferential(submittersForReferential); |
|
| 229 | 233 |
log.error("Sumbitters created for referential check: " + submittersForReferential.size());
|
| 230 | 234 |
|
| 231 | 235 |
} |
Also available in: Unified diff
updated cris listener to support new executors