final CountDownLatch endLatch = new CountDownLatch(threadCount);
        final AtomicInteger errorCount = new AtomicInteger(0);

        // Set initial values
        testRule.setRuleId("concurrentRule");
        TestResponseProcessor processor = new TestResponseProcessor();
        testRule.setResponseProcessor(processor);

        for (int i = 0; i < threadCount; i++) {
            final int threadId = i;

    /**
     * Test concurrent rule matching
     */
    public void test_concurrentRuleMatching() throws Exception {
        final ConfigurableRule rule = new ConfigurableRule();
        rule.setRuleId("concurrentRule");
        rule.setResponseProcessor(new TestResponseProcessor("concurrentProcessor"));
        rule.addCondition("url", "https://.*\\.example\\.com/.*");

        final int threadCount = 10;