Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- (...)
- public class RedisService {
- 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(RedisTemplate<String, Object> redisTemplate, String serviceId, String workQueue,
- String doneQueue) {
- this.redisTemplate = redisTemplate;
- this.serviceId = serviceId;
- this.workQueue = workQueue;
- this.doneQueue = doneQueue;
- }
- 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("Attempting to push null/blank message to: " + listName + ". Skipping!");
- return;
- }
- try {
- if (priority) {
- redisTemplate.opsForList().rightPush(listName, message);
- } else {
- redisTemplate.opsForList().leftPush(listName, message);
- }
- LOGGER.info("Pushed to: " + listName + " Message: " + message);
- } catch (Exception e) {
- LOGGER.error("Problem adding message to: " + listName, e);
- }
- }
- (...)
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement