Your producer send the xxxxyyy body to the endpoint "direct:start".
Do you have any route using this endpoint? If not then nothing happens.
On Tue, Aug 18, 2009 at 7:15 PM, Mick Knutson<mknut...@baselogic.com> wrote:
> Now,
>
> 1. I added the suggestion to my client-camel-context.xml such as:
>
> * <!-- Create a client Camel Context -->
> <camel:camelContext id="camel">
> <camel:packageScan>
>
> <camel:package>com.wiredducks.service.routes.test</camel:package>
> <camel:excludes>**.*Excluded*</camel:excludes>
> <camel:includes>**.*</camel:includes>
> </camel:packageScan>
>
> <!-- Create a Consumer so we can consume messages -->
> <camel:consumerTemplate id="consumer" />
> </camel:camelContext>
> *
>
> 2. Then I added the rout you said:
>
> �...@override
> public void configure() throws Exception {
>
>
> from("activemq://Consumer.A.VirtualTopic.TEST").to("seda:TESTING").to("mock://resultClient1");
>
> } // end configure
>
>
> 3. I un-commented the mock assertions in my JUnit:
>
>
> *MockEndpoint resultClient1 = camel.getEndpoint("mock://resultClient1",
> MockEndpoint.class);
> ... then ...
> resultClient1.expectedMessageCount(1);
> *
> *
> // Send the test message to make Server Service create our Status
> Message
> producerTemplate.sendBody("xxyyzz");
>
> // now lets assert that the mock endpoint received messages
> resultClient1.assertIsSatisfied();
> *
>
>
>
> NOW:
>
> A. I did not see Consumer.1 MDP did NOT get the message now.
>
> B. *resultClient1 *expected 1 message but received zero messages.*
>
> *
>
>
>
>
>
> ---
> Thank You…
>
> Mick Knutson, President
>
> BASE Logic, Inc.
> Enterprise Architecture, Design, Mentoring & Agile Consulting
> p. (866) BLiNC-411: (254-6241-1)
> f. (415) 685-4233
>
> Website: http://baselogic.com
> Linked IN: http://linkedin.com/in/mickknutson
> Vacation Rental: http://tahoe.baselogic.com
> ---
>
>
>
> On Tue, Aug 18, 2009 at 12:27 PM, Mick Knutson <mknut...@baselogic.com>wrote:
>
>> I tried this, but I get a failure on my Mock.
>>
>> Let me try to step through what I have working:
>>
>> 1. I start up a camel server via mvn camel:run
>> 2. The camel server starts the following route:
>>
>> * @Override
>> public void configure() throws Exception {
>> // add tracer as an interceptor so it will log the exchange
>> executions at runtime
>> // this can aid us to understand/see how the exchanges is routed
>> etc.
>> getContext().addInterceptStrategy(new Tracer());
>>
>> from("jms:queue:bets").process(new PlaceBet());
>>
>> from("seda:pushStatusUpdate")
>> .process(new VirtualTopicAuditor())
>> .to(TableServiceImpl.VIRTUAL_TOPIC);
>> }
>> *
>>
>> 3. In another command prompt, I start my unit test which starts another
>> client camel context like this:
>>
>> *<!-- Create a client Camel Context -->*
>> * <camel:camelContext id="camel">*
>> * <camel:packageScan>*
>> *
>> <camel:package>com.wiredducks.service.routes.test</camel:package>*
>> * <camel:excludes>**.*Excluded*</camel:excludes>*
>> * <camel:includes>**.*</camel:includes>*
>> * </camel:packageScan>*
>>
>> * <!-- Create a Consumer so we can consume messages -->*
>> * <camel:consumerTemplate id="consumer" />*
>> * </camel:camelContext>*
>>
>> * <!-- Create a Producer so we can send messages -->*
>> * <camel:template id="producer" />*
>>
>> * <bean id="jms"
>> class="org.apache.activemq.camel.component.ActiveMQComponent">*
>> * <property name="brokerURL" value="tcp://localhost:61616" />*
>> * </bean>*
>>
>> * <bean id="connectionFactory"
>> class="org.apache.activemq.ActiveMQConnectionFactory">*
>> * <property name="brokerURL" value="tcp://localhost:61616" />*
>> * </bean>*
>>
>> * <bean id="transactionManager"*
>> * class="org.springframework.jms.connection.JmsTransactionManager">
>> *
>> * <property name="connectionFactory" ref="connectionFactory" />*
>> * </bean>*
>> * <import resource="clients/test-client1.xml" />*
>> ....*
>> <import resource="clients/test-client11.xml" />*
>>
>>
>> *</beans>*
>>
>>
>> 4. Each client MDP is created and just prints out the message received by
>> onMessage()
>>
>> *<bean id="test-client1"
>> class="com.wiredducks.service.impl.StatusUpdateService">
>> <property name="name" value="test-client1" />
>> <property name="seat" value="1" />
>> </bean>
>>
>> <jms:listener-container transaction-manager="transactionManager" >
>> <jms:listener destination="Consumer.1.VirtualTopic.TEST"
>> ref="test-client1"
>> method="onMessage" />
>> </jms:listener-container>
>> *
>>
>>
>> 5. My unit tests just forces a message to be sent by calling a
>> sendStatusUpdate message from the camel server:
>>
>> *...@autowired*
>> * protected SpringCamelContext camel;*
>>
>> * �...@endpointinject(uri = "mock://resultClient1")*
>> * protected MockEndpoint resultClient1;*
>> * *
>> * �...@produce(uri = "direct:start")*
>> * protected ProducerTemplate producerTemplate;*
>>
>> * �...@test*
>> * public void testSendBetMessage() throws Exception {** *
>> * *
>> * //MockEndpoint resultClient1 =
>> camel.getEndpoint("mock://resultClient1", MockEndpoint.class);***
>> * *
>> * resultClient1.expectedMessageCount(1);*
>>
>> * // Send the test message to make Server Service create our Status
>> Message*
>> * producerTemplate.sendBody("xxyyzz");*
>> * *
>> * // now lets assert that the mock endpoint received messages*
>> * //resultClient1.assertIsSatisfied();** *
>> * }*
>>
>> 6. The server sends a status update message:
>>
>> *public boolean sendStatusUpdate(String body) {** ** *
>> * Map<String, Object> gameState = new HashMap<String, Object>();*
>> * gameState.put("tableId", "123");*
>> * gameState.put("player1", "raise");*
>>
>> * //Send message to *
>> * producer.sendBodyAndHeader("seda:pushStatusUpdate", gameState,
>> "tableId", "123");*
>> * return true;*
>> * }*
>>
>> 7. Each of the clients that where setup in the camel client will get the
>> message just fine. I have tested this with 10 clients now.
>>
>> *** In the next email, I will elaborate on the change you suggested.
>> ******NOTE: I commented out *//resultClient1.assertIsSatisfied();* in
>> order to get the original test to work.
>>
>>
>>
>> ---
>> Thank You…
>>
>> Mick Knutson, President
>>
>> BASE Logic, Inc.
>> Enterprise Architecture, Design, Mentoring & Agile Consulting
>> p. (866) BLiNC-411: (254-6241-1)
>> f. (415) 685-4233
>>
>> Website: http://baselogic.com
>> Linked IN: http://linkedin.com/in/mickknutson
>> Vacation Rental: http://tahoe.baselogic.com
>> ---
>>
>>
>>
>> On Mon, Aug 17, 2009 at 7:34 AM, Willem Jiang <willem.ji...@gmail.com>wrote:
>>
>>> If you want to use Mock endpoint to validate the message, you just need to
>>> create the route rule like this
>>>
>>> from("CosumerA.Virtual.Topic").to("mock:endpoint");
>>>
>>> You don't need to create the MDP yourself.
>>>
>>> Willem
>>>
>>>
>>> Mick Knutson wrote:
>>>
>>>> I finally got a working JUnit test that creates a MDP, subscribes to a
>>>> AMQ
>>>> Virtual Topic, and receives a message. But now that the MDP gets the
>>>> message
>>>> I am having an issue validating that message.
>>>>
>>>> How can I re-route this message to a MOCK just for testing purposes?
>>>>
>>>> ---
>>>> Thank You…
>>>>
>>>> Mick Knutson, President
>>>>
>>>> BASE Logic, Inc.
>>>> Enterprise Architecture, Design, Mentoring & Agile Consulting
>>>> p. (866) BLiNC-411: (254-6241-1)
>>>> f. (415) 685-4233
>>>>
>>>> Website: http://baselogic.com
>>>> Linked IN: http://linkedin.com/in/mickknutson
>>>> Vacation Rental: http://tahoe.baselogic.com
>>>> ---
>>>>
>>>>
>>>
>>
>
--
Claus Ibsen
Apache Camel Committer
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
