Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- (...)
- public class RedisService {
- private static final String ADDING_EMPTY_MESSAGE_TO_LIST_ERROR =
- "Attempting to push null/blank message to: %s. Skipping!";
- private static final String SUCCESSFUL_ADDING_MESSAGE_TO_LIST =
- "Pushed to: %s Message: %s";
- private static final String PROBLEM_ADDING_MESSAGE_ERROR =
- "Problem adding message to: %s";
- private String workQueue;
- private String doneQueue;
- private String serviceId;
- private static final Logger LOGGER = LoggerFactory.getLogger(RedisService.class);
- private RedisTemplate<String, Object> redisTemplate;
- public RedisService(String workQueue,
- String doneQueue,
- String serviceId,
- RedisTemplate<String, Object> redisTemplate) {
- this.workQueue = workQueue;
- this.doneQueue = doneQueue;
- this.serviceId = serviceId;
- this.redisTemplate = redisTemplate;
- }
- public String getWorkQueue() {
- return workQueue;
- }
- public String getDoneQueue() {
- return doneQueue;
- }
- public void addToList(String listName, String message, boolean priority) {
- if (!StringUtils.isNotBlank(message)) {
- LOGGER.error(String.format(ADDING_EMPTY_MESSAGE_TO_LIST_ERROR, listName));
- return;
- }
- try {
- if (priority) {
- redisTemplate.opsForList().rightPush(listName, message);
- } else {
- redisTemplate.opsForList().leftPush(listName, message);
- }
- LOGGER.info(SUCCESSFUL_ADDING_MESSAGE_TO_LIST, listName, message);
- } catch (Exception e) {
- LOGGER.error(String.format(PROBLEM_ADDING_MESSAGE_ERROR, listName), e);
- }
- }
- (...)
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement