package com.xcong.excoin.common.listener;
|
|
import com.xcong.excoin.utils.mail.ZzSmsSend;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.data.redis.connection.Message;
|
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
|
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* @author wzy
|
* @date 2021-04-16
|
**/
|
@Slf4j
|
@Component
|
@ConditionalOnProperty(prefix = "app", name = "newest-price-update-job", havingValue = "true")
|
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {
|
|
public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
|
super(listenerContainer);
|
}
|
|
@Override
|
public void onMessage(Message message, byte[] pattern) {
|
String expireKey = message.toString();
|
if (expireKey.equalsIgnoreCase("whole_bomb_execute")) {
|
ZzSmsSend.sendVerifyCode("15773002834", "123456", 2);
|
}
|
}
|
}
|
