1234567891011121314151617181920212223242526272829303132 |
- package org.jeecg.common.modules.redis.client;
- import org.jeecg.common.base.BaseMap;
- import org.jeecg.common.constant.GlobalConstants;
- import org.springframework.context.annotation.Configuration;
- import org.springframework.data.redis.core.RedisTemplate;
- import javax.annotation.Resource;
- /**
- * redis客户端
- */
- @Configuration
- public class JeecgRedisClient {
- @Resource
- private RedisTemplate<String, Object> redisTemplate;
- /**
- * 发送消息
- *
- * @param handlerName
- * @param params
- */
- public void sendMessage(String handlerName, BaseMap params) {
- params.put(GlobalConstants.HANDLER_NAME, handlerName);
- redisTemplate.convertAndSend(GlobalConstants.REDIS_TOPIC_NAME, params);
- }
- }
|