Advertisement
viraco4a

Suggestion

Mar 13th, 2019
117
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.77 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(RedisTemplate<String, Object> redisTemplate, String serviceId, String workQueue,
  22. String doneQueue) {
  23. this.redisTemplate = redisTemplate;
  24. this.serviceId = serviceId;
  25. this.workQueue = workQueue;
  26. this.doneQueue = doneQueue;
  27. }
  28.  
  29. public String getWorkQueue() {
  30. return workQueue;
  31. }
  32.  
  33. public String getDoneQueue() {
  34. return doneQueue;
  35. }
  36.  
  37. public void addToList(String listName, String message, boolean priority) {
  38. if (!StringUtils.isNotBlank(message)) {
  39. LOGGER.error(String.format(ADDING_EMPTY_MESSAGE_TO_LIST_ERROR, listName));
  40. return;
  41. }
  42. try {
  43. if (priority) {
  44. redisTemplate.opsForList().rightPush(listName, message);
  45. } else {
  46. redisTemplate.opsForList().leftPush(listName, message);
  47. }
  48. LOGGER.info(SUCCESSFUL_ADDING_MESSAGE_TO_LIST, listName, message);
  49. } catch (Exception e) {
  50. LOGGER.error(String.format(PROBLEM_ADDING_MESSAGE_ERROR, listName), e);
  51. }
  52. }
  53.  
  54. (...)
  55. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement