package cn.tr.plugin.eventbus;

import cn.tr.plugin.eventbus.redisson.RedissonEventBus;
import cn.tr.plugin.test.ut.BaseRedisUnitTest;
import org.greenrobot.eventbus.EventBus;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;

/**
 * @ClassName : RedissonEventBusTest
 * @Description :
 * @Author : LF
 * @Date: 2023年03月16日
 */

public class RedissonEventBusTest extends BaseRedisUnitTest {
    private EventBus eventBus;
    @Autowired
    private RedissonClient redissonClient;


    @BeforeEach
    public void init(){
        eventBus=new RedissonEventBus(redissonClient);
        eventBus.register(new EventBusTest.StringListener());
    }

    @Test
    public void pub(){
        for (int i = 0; i < 100; i++) {
            eventBus.post(String.valueOf(i));
        }
    }
}