Mailing-List: contact camel-user-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: camel-user@activemq.apache.org
Received-SPF: neutral (athena.apache.org: local policy)
Message-ID: <56b1dfc30810011824m4069e5f6w92291618307b4e35@mail.gmail.com>
Date: Wed, 1 Oct 2008 18:24:14 -0700
From: "Mick Knutson" <mknutson@baselogic.com>
To: camel-user@activemq.apache.org
Subject: Re: Trying to understand how to deal with process() errors and
 creating an exceptionChannel for bad messages.
In-Reply-To: <56b1dfc30809261024r42d6d916me2109c6b848b5ecd@mail.gmail.com>
MIME-Version: 1.0
Content-Type: multipart/alternative;
	boundary="----=_Part_66975_20296761.1222910654071"
References: <56b1dfc30809251240g256ecd89l874910502ca98c78@mail.gmail.com>
	 <4C1FB9C00D24A140906239533638C4D205716715@EXVS04.exserver.dk>
	 <56b1dfc30809261024r42d6d916me2109c6b848b5ecd@mail.gmail.com>

------=_Part_66975_20296761.1222910654071
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit
Content-Disposition: inline

So I have gotten a bit further, but not all the way.

It appears that if I have a unit test that is overloaded as I can do in
TestNG, then I can seemingly re-use the same mock endpoints.
Here is a valid test that is overloaded 3 different times:

    *@Test(groups = {"functional"})
    @Parameters({"startEndpointUri", "successEndpointUri",
"errorEndpointUri", "messageInputBody"})
    public void testCreateInvalidChangeRequest(String startEndpointUri,
                                               String successEndpointUri,
                                               String errorEndpointUri,
                                               String messageInputBody
    )
            throws Exception {

        MockEndpoint mockSuccessEndpoint =
getMockEndpoint(successEndpointUri);
        MockEndpoint mockFailureEndpoint =
getMockEndpoint(errorEndpointUri);

        mockFailureEndpoint.expectedBodiesReceived(messageInputBody);
        mockFailureEndpoint.expectedMessageCount(1);
        mockSuccessEndpoint.expectedMessageCount(0);

        try {
            // Create and Send message to input queue
            camelContext.addRoutes(
                    createRoute(startEndpointUri,
                            changeRequestProcessor,
                            successEndpointUri,
                            errorEndpointUri
                    )
            );

            producerTemplate.sendBody(startEndpointUri, messageInputBody);

            Assert.fail("Should have thrown a RuntimeCamelException");
        } catch (RuntimeCamelException e) {
            assertIsInstanceOf(e, RuntimeCamelException.class);
        }

        // this is optional.
        testMocksAreValid();

        MockEndpoint.assertIsSatisfied(mockFailureEndpoint,
mockSuccessEndpoint);
    }
*


Now here is the kicker, when I have another test method in this class
running with the same endpoint values:


    *@Test(groups = {"functional"})
    @Parameters({"startEndpointUri", "successEndpointUri",
"errorEndpointUri", "messageInputBody"})
    public void testCreateValidRequest(String startEndpointUri,
                                       String successEndpointUri,
                                       String errorEndpointUri,
                                       String messageInputBody
    )
            throws Exception {
        MockEndpoint mockSuccessEndpoint =
getMockEndpoint(successEndpointUri);
        MockEndpoint mockFailureEndpoint =
getMockEndpoint(errorEndpointUri);

        mockSuccessEndpoint.expectedMessageCount(1);

mockSuccessEndpoint.message(0).header(Constants.REQUEST_DESTINATION).isEqualTo(Constants.CHANNEL_GG_CS_COMMAND_CLUSTER);

        mockFailureEndpoint.expectedMessageCount(0);

        try {
            // setup RouteBuilder...
            // Create and Send message to input queue
            camelContext.addRoutes(
                    createRoute(startEndpointUri,
                            changeRequestProcessor,
                            successEndpointUri,
                            errorEndpointUri
                    )
            );

            // Create and Send message to input queue
            producerTemplate.sendBodyAndHeader(startEndpointUri,
messageInputBody, Constants.COMMAND_TYPE, Constants.PROVISION);

        } catch (RuntimeCamelException e) {
            Assert.fail("Should have thrown a RuntimeCamelException");
        }

        testMocksAreValid();

        MockEndpoint.assertIsSatisfied(mockSuccessEndpoint,
mockFailureEndpoint);
    }
*

*
I get the following errors:*

*<test name="InvalidChangeRequest-bad-commandType">
.....
<exception class="java.lang.AssertionError">
            <message>
              <![CDATA[mock:error Received message count. Expected: <1> but
was: <2>]]>
            </message>
*


So the mock:error queue is not getting cleaned up and there is an extra
message.

So how on earth do I DELETE or RESET or CLEAR this mock? I have spun through
each one and ran mock.reset() but that did not help.

------=_Part_66975_20296761.1222910654071--