package com.fastbee.mqtt.manager;

import com.fastbee.mqtt.model.WillMessage;
import lombok.extern.slf4j.Slf4j;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;


@Slf4j
public class WillMessageManager {

    private static Map<String, WillMessage> map = new ConcurrentHashMap<>();

    public static void push(WillMessage message){
        map.put(message.getClientId(),message);
    }

    public static void pop(String clientId){
        try {
            WillMessage message = map.get(clientId);
            if (null == message){
                return;
            }
            ClientManager.pubTopic(message.getMessage());
        }catch (Exception e){
            log.error("=>发送客户端[{}],遗嘱消息异常",e.getMessage(),e);
        }
    }
}