final Map<String, Object> map = new HashMap<>();
        map.put(FieldNames.TEXT, StringUtil.EMPTY);

        for (int i = 0; i < readings.length; i++) {
            map.put(FieldNames.READING_PREFIX + i, new String[] {});
        }

        map.put(FieldNames.FIELDS, new String[] {});
        map.put(FieldNames.TAGS, new String[] {});
        map.put(FieldNames.ROLES, new String[] {});

        RealisticTestBean bean1 = new RealisticTestBean();
        TestBean bean2 = new TestBean();

        PlexusConfiguration config1 = new XmlPlexusConfiguration("name");
        config1.setValue("testValue");
        optimizedHelper.setProperty(bean1, "name", String.class, config1);
        optimizedHelper.setProperty(bean2, "name", String.class, config1);

        PlexusConfiguration config2 = new XmlPlexusConfiguration("count");

    private final AtomicLong totalFailures = new AtomicLong(0);
    private final AtomicLong totalSuccesses = new AtomicLong(0);
    private final AtomicLong totalCircuitOpenRejections = new AtomicLong(0);
    private final AtomicLong totalTimeInOpen = new AtomicLong(0);
    private final AtomicLong openStateStartTime = new AtomicLong(0);

    // Event listeners

                // j2ee types
                new DefaultType("ejb", Language.JAVA_FAMILY, "jar", null, false, JavaPathType.CLASSES),
                new DefaultType("ejb-client", Language.JAVA_FAMILY, "jar", "client", false, JavaPathType.CLASSES),
                new DefaultType("war", Language.JAVA_FAMILY, "war", null, true),
                new DefaultType("ear", Language.JAVA_FAMILY, "ear", null, true),

        String[] words = new String[] { "検索", "エンジン" };
        String[][] readings = new String[][] { new String[] { "kensaku" }, new String[] { "enjin" } };
        String[] fields = new String[] { "content" };
        String[] tags = new String[] { "tag1" };
        String[] roles = new String[] { "role1" };
        String[] langs = new String[] { "ja" };

    return ImmutableList.<BlockingQueue<Object>>of(
        new LinkedBlockingQueue<Object>(),
        new LinkedBlockingQueue<Object>(10),
        new SynchronousQueue<Object>(),
        new ArrayBlockingQueue<Object>(10),
        new LinkedBlockingDeque<Object>(),
        new LinkedBlockingDeque<Object>(10),
        new PriorityBlockingQueue<Object>(10, Ordering.arbitrary()));
  }

  /*

    DataInput in = new LittleEndianDataInputStream(new ByteArrayInputStream(data));
    byte[] b = new byte[data.length];
    in.readFully(b);
    assertEquals(Bytes.asList(data), Bytes.asList(b));
  }

  public void testReadUnsignedByte_eof() throws IOException {
    DataInput in = new LittleEndianDataInputStream(new ByteArrayInputStream(new byte[0]));

    }

    @Test
    @DisplayName("Test force cleanup")
    @Timeout(value = 5, unit = TimeUnit.SECONDS)
    void testForceCleanup() {
        TestResource resource1 = new TestResource("cleanup1");
        TestResource resource2 = new TestResource("cleanup2");

        resourceManager.registerResource(resource1);
        resourceManager.registerResource(resource2);

        assertFalse(resource1.isClosed());

        SetTestSuiteBuilder.using(
                new TestStringSetGenerator() {
                  @Override
                  protected Set<String> create(String[] elements) {
                    // Put the sets in different orders for the hell of it
                    return union(
                        new LinkedHashSet<>(asList(elements[0], elements[1], elements[2])),

        NullResponseProcessor processor = new NullResponseProcessor();
        ResponseData responseData1 = new ResponseData();
        responseData1.setUrl("https://example.com/page1");

        ResponseData responseData2 = new ResponseData();
        responseData2.setUrl("https://example.com/page2");

        ResponseData responseData3 = new ResponseData();
        responseData3.setUrl("https://example.com/page3");