Advertisement
viraco4a

Original

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