NB_NetPump/nb-admin/src/test/java/com/nb/admin/DelayMessageTest.java

package com.nb.admin;

import com.nb.AdminApplication;
import com.nb.bus.hospital.config.HospitalDeviceAutoUndoConfigHandler;
import com.nb.bus.hospital.config.handler.HandlerConstant;
import com.nb.core.Value;
import com.nb.common.queue.delay.manager.DelayMessageManager;
import com.nb.common.queue.delay.message.DelayMessage;
import com.nb.common.queue.delay.message.DelayMessageProperties;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.Date;
import java.util.concurrent.TimeUnit;

/**
 * @author lifang
 * @version 1.0.0
 * @ClassName DelayMessageTest.java
 * @Description TODO
 * @createTime 2022年07月09日 08:37:00
 */
@RunWith(SpringRunner.class)
@Slf4j
@SpringBootTest(classes = AdminApplication.class)
public class DelayMessageTest {
    @Autowired
    DelayMessageManager delayMessageManager;
    @Test
    public void test(){
        HospitalDeviceAutoUndoConfigHandler.UndoEntity timestamp = HospitalDeviceAutoUndoConfigHandler.UndoEntity.builder().timestamp(new Date()).build();
        DelayMessage delayMessage = new DelayMessage(Value.simple(timestamp), HandlerConstant.DEVICE_AUTO_UNDO, DelayMessageProperties.of(TimeUnit.SECONDS, 30));
        delayMessageManager.add(delayMessage);
        while (true){

        }
    }
}