Advertisement
viraco4a

Suggestion

Mar 13th, 2019
139
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.82 KB | None | 0 0
  1. (...)
  2. public class RedisService {
  3.  
  4. private static final String ADDING_EMPTY_MESSAGE_TO_LIST_ERROR =
  5. "Attempting to push null/blank message to: %s. Skipping!";
  6. private static final String SUCCESSFUL_ADDING_MESSAGE_TO_LIST =
  7. "Pushed to: %s Message: %s";
  8. private static final String PROBLEM_ADDING_MESSAGE_ERROR =
  9. "Problem adding message to: %s";
  10.  
  11. private String workQueue;
  12.  
  13. private String doneQueue;
  14.  
  15. private String serviceId;
  16.  
  17. private static final Logger LOGGER = LoggerFactory.getLogger(RedisService.class);
  18.  
  19. private RedisTemplate<String, Object> redisTemplate;
  20.  
  21. public RedisService(String workQueue,
  22. String doneQueue,
  23. String serviceId,
  24. RedisTemplate<String, Object> redisTemplate) {
  25. this.workQueue = workQueue;
  26. this.doneQueue = doneQueue;
  27. this.serviceId = serviceId;
  28. this.redisTemplate = redisTemplate;
  29. }
  30.  
  31. public String getWorkQueue() {
  32. return workQueue;
  33. }
  34.  
  35. public String getDoneQueue() {
  36. return doneQueue;
  37. }
  38.  
  39. public void addToList(String listName, String message, boolean priority) {
  40. if (!StringUtils.isNotBlank(message)) {
  41. LOGGER.error(String.format(ADDING_EMPTY_MESSAGE_TO_LIST_ERROR, listName));
  42. return;
  43. }
  44. try {
  45. if (priority) {
  46. redisTemplate.opsForList().rightPush(listName, message);
  47. } else {
  48. redisTemplate.opsForList().leftPush(listName, message);
  49. }
  50. LOGGER.info(SUCCESSFUL_ADDING_MESSAGE_TO_LIST, listName, message);
  51. } catch (Exception e) {
  52. LOGGER.error(String.format(PROBLEM_ADDING_MESSAGE_ERROR, listName), e);
  53. }
  54. }
  55.  
  56. (...)
  57. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement