if (queueSize < 1 || batchMaxSize < 1) {
            throw new IllegalArgumentException("Queue and batch sizes must be greater than 1");
        }
        this.batchMaxSize = batchMaxSize;
        this.blockOnLastEvent = blockOnLastEvent;

        this.eventQueue = new ArrayBlockingQueue<>(queueSize);
        Thread updater = new Thread(this::feedConsumer);
        updater.setDaemon(true);
        updater.start();

        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            @Override
            public String getOsddLinkEnabled() {
                return "auto";
            }

            @Override
            public String getSsoType() {
                return "none";
            }
        });
        final OsddHelper osddHelper = new OsddHelper();

    private final Completion completed;

    static TimedThread createWithDelay(long countdownInMillis) {
      return new TimedThread(countdownInMillis);
    }

    private TimedThread(long expectedCompletionWaitMillis) {
      completed = new Completion(expectedCompletionWaitMillis);
      thread = new Thread(new JoinTarget(expectedCompletionWaitMillis));
      thread.start();
    }

    void joinSuccessfully() {

public class ActivityHelperTest extends UnitFessTestCase {

    private ActivityHelper activityHelper;

    private ThreadLocal<String> localLogMsg = new ThreadLocal<>();

    @Override
    protected void setUp(TestInfo testInfo) throws Exception {
        super.setUp(testInfo);
        activityHelper = new ActivityHelper() {
            @Override
            protected void printByLtsv(final Map<String, String> valueMap) {

    void multipleWriteBodyWireFormat_shouldProduceSameResult() {
        // Arrange
        Name realName = new Name(mockConfig, "SERVER", 0x20, "domain.local");
        nodeStatusRequest = new NodeStatusRequest(mockConfig, realName);
        byte[] dst1 = new byte[100];
        byte[] dst2 = new byte[100];

        // Act
        int result1 = nodeStatusRequest.writeBodyWireFormat(dst1, 0);

        DynamicProperties systemProps = new DynamicProperties(file);
        ComponentUtil.register(systemProps, "systemProperties");

        relatedContentHelper = new RelatedContentHelper() {
            @Override
            public List<RelatedContent> getAvailableRelatedContentList() {
                return mockBhv.getTestData();
            }
        };

        mockBhv = new MockRelatedContentBhv();

                return (T) new DefaultArtifactResolver();
            } else if (clazz == ArtifactManager.class) {
                return (T) new DefaultArtifactManager(this);
            } else if (clazz == RepositoryFactory.class) {
                return (T) new DefaultRepositoryFactory(new DefaultRemoteRepositoryManager(
                        new DefaultUpdatePolicyAnalyzer(),
                        new DefaultChecksumPolicyProvider(),

    @Test
    @DisplayName("readn should handle EOF correctly")
    void testReadnEOF() throws IOException {
        byte[] buffer = new byte[10];
        ByteArrayInputStream bais = new ByteArrayInputStream(new byte[0]);

        int bytesRead = SessionServicePacket.readn(bais, buffer, 0, 5);

        assertEquals(0, bytesRead);
    }

    @Test
    @DisplayName("readn should handle multiple read calls")

        assertEquals(new BigDecimal("100"), BigDecimalConversionUtil.toBigDecimal(Integer.valueOf(100)));
        assertEquals(new BigDecimal("1000"), BigDecimalConversionUtil.toBigDecimal(Long.valueOf(1000L)));

        assertEquals(0, new BigDecimal("0.1").compareTo(BigDecimalConversionUtil.toBigDecimal(Float.valueOf(0.1F))));

    }

    @Test
    void testEquals() {
        ToolchainModel tm1 = new ToolchainModel();
        tm1.setType("jdk");
        tm1.addProvide("version", "1.5");
        tm1.addProvide("vendor", "sun");
        Xpp3Dom configuration1 = new Xpp3Dom("configuration");
        Xpp3Dom jdkHome1 = new Xpp3Dom("jdkHome");
        jdkHome1.setValue("${env.JAVA_HOME}");
        configuration1.addChild(jdkHome1);