diff --git a/src/main/java/com/epam/reportportal/analyzer/index/IndexerServiceClientImpl.java b/src/main/java/com/epam/reportportal/analyzer/index/IndexerServiceClientImpl.java index 45e036d..363dd5c 100644 --- a/src/main/java/com/epam/reportportal/analyzer/index/IndexerServiceClientImpl.java +++ b/src/main/java/com/epam/reportportal/analyzer/index/IndexerServiceClientImpl.java @@ -46,7 +46,7 @@ public class IndexerServiceClientImpl implements IndexerServiceClient { @Autowired public IndexerServiceClientImpl(RabbitMqManagementClient rabbitMqManagementClient, - @Qualifier("rabbitTemplate") RabbitTemplate rabbitTemplate) { + @Qualifier("analyzerRabbitTemplate") RabbitTemplate rabbitTemplate) { this.rabbitMqManagementClient = rabbitMqManagementClient; this.rabbitTemplate = rabbitTemplate; } diff --git a/src/main/java/com/epam/reportportal/jobs/clean/DeleteExpiredUsersJob.java b/src/main/java/com/epam/reportportal/jobs/clean/DeleteExpiredUsersJob.java index aef4d0b..9556dd0 100644 --- a/src/main/java/com/epam/reportportal/jobs/clean/DeleteExpiredUsersJob.java +++ b/src/main/java/com/epam/reportportal/jobs/clean/DeleteExpiredUsersJob.java @@ -134,7 +134,6 @@ public void execute() { private List findUsersAndPersonalProjects() { MapSqlParameterSource params = new MapSqlParameterSource(); - params.addValue("now_ms", System.currentTimeMillis()); params.addValue(RETENTION_PERIOD, lastLoginBorder()); RowMapper rowMapper = (rs, rowNum) -> {