| | |
| | | // cache clear |
| | | if (System.currentTimeMillis() > CACHE_VALID_TIME) { |
| | | routeCountEachJob.clear(); |
| | | CACHE_VALID_TIME = System.currentTimeMillis() + 1000*60*60*24; |
| | | CACHE_VALID_TIME = System.currentTimeMillis() + 1000 * 60 * 60 * 24; |
| | | } |
| | | |
| | | AtomicInteger count = routeCountEachJob.get(jobId); |
| | |
| | | |
| | | @Override |
| | | public ReturnT<String> route(TriggerParam triggerParam, List<String> addressList) { |
| | | String address = addressList.get(count(triggerParam.getJobId())%addressList.size()); |
| | | String address = addressList.get(count(triggerParam.getJobId()) % addressList.size()); |
| | | return new ReturnT<String>(address); |
| | | } |
| | | |