I have found the reason : the line
"template.sendBody(Model.generateModel(
EmxMessageType.VRES.getValue(), Model.getInVresMessage()) );"
must be put after "resultEndpoint.expectedBodiesReceived( expected );"
Why : I DON'T KNOW
@Test
@DirtiesContext
public void testModeltoCsv() throws Exception {
resultEndpoint.expectedMessageCount(1);
resultEndpoint.expectedBodiesReceived( expected );
template.sendBody(Model.generateModel(
EmxMessageType.VRES.getValue(), Model.getInVresMessage()) );
resultEndpoint.assertIsSatisfied();
}
Charles Moulliard
Senior Enterprise Architect
Apache Camel Committer
*****************************
blog : http://cmoulliard.blogspot.com
twitter : http://twitter.com/cmoulliard
On Fri, Oct 23, 2009 at 1:16 PM, Charles Moulliard <[email protected]> wrote:
> I have also this issue with the following test (the code is based on
> what I have done in camel-bindy where there are 25 unit tests like
> this one) :
>
> �...@test
> �...@dirtiescontext
> public void testModeltoCsv() throws Exception {
>
> template.sendBody(Model.generateModel(
> EmxMessageType.VRES.getValue(), Model.getInVresMessage()) );
>
> resultEndpoint.expectedMessageCount(1);
> resultEndpoint.expectedBodiesReceived( expected );
>
> resultEndpoint.assertIsSatisfied();
> }
>
> �...@configuration
> public static class ContextConfig extends SingleRouteCamelConfiguration {
>
> BindyCsvDataFormat csvBindyDataFormat = new
> BindyCsvDataFormat("com.xpectis.x3s.model.backoffice.emx.vres.in");
>
> �...@override
> �...@bean
> public RouteBuilder route() {
> return new RouteBuilder() {
> �...@override
> public void configure() {
> from("direct:start")
> .marshal(csvBindyDataFormat)
> .to("mock:result");
> }
> };
> }
> }
>
>
> FYI, the result generated by marshal method of camel-bindy is not null :
>
> for (Map<String, Object> model : models) {
>
> String result = factory.unbind(model);
> LOG.info(">>>> String generated : " + result); // CONTENT
> OF STRING IS NOT NULL
> byte[] bytes =
> exchange.getContext().getTypeConverter().convertTo(byte[].class,
> exchange, result);
> outputStream.write(bytes);
>
> // Add a carriage return
> outputStream.write(bytesCRLF);
> }
>
> Charles Moulliard
> Senior Enterprise Architect
> Apache Camel Committer
>
> *****************************
> blog : http://cmoulliard.blogspot.com
> twitter : http://twitter.com/cmoulliard
>
>
>
> On Fri, Oct 23, 2009 at 12:40 PM, Willem Jiang <[email protected]> wrote:
>> I don't know why the resultEndpoint can't receive any message.
>>
>> chris, are you using spring configuration.
>> Can you check if the resultEndpoint is injected rightly?
>>
>> Willem
>>
>> Claus Ibsen wrote:
>>>
>>> The B[ stuff is Java way of telling its a byte array
>>>
>>> Force Camel to test against String etc
>>>
>>>> // resultEndpoint.expectedBodiesReceived(result);
>>>
>>> Could be
>>> resultEndpoint.message(0).body(String.class).isEqualTo(result);
>>>
>>> I guess we should add that type converter stuff into
>>> expectedBodiesReceived as well.
>>>
>>>
>>>
>>> On Fri, Oct 23, 2009 at 11:01 AM, Charles Moulliard
>>> <[email protected]> wrote:
>>>>
>>>> I have created a unit test to unmarshal a FIX message into a model
>>>> (copy the model into another one) and marshal the result into a CSV
>>>>
>>>> The result received by the mock is null. If I try to read the object,
>>>> I have this :
>>>>
>>>>>>> Class : [B
>>>>>>> CSV generated : [...@12b19c5
>>>>
>>>> Remark : the FIX message is well transformed into a model of objects
>>>> and bindy does not generate any error during the generation of the
>>>> outputstream from the model object
>>>>
>>>> public class VresEmxToCsvTest extends AbstractJUnit4SpringContextTests {
>>>>
>>>> private static final transient Log LOG =
>>>> LogFactory.getLog(VresEmxToCsvTest.class);
>>>>
>>>> @Produce(uri = "direct:start")
>>>> private ProducerTemplate template;
>>>>
>>>> @EndpointInject(uri = "mock:result")
>>>> private MockEndpoint resultEndpoint;
>>>>
>>>>
>>>> @Test
>>>> @DirtiesContext
>>>> public void testEmxtoCsv() throws Exception {
>>>>
>>>> String record =
>>>> "8=FIX.4.1 9=980 35=U3 34=61 49=SERVER 50=EMXSV 52=20091021-14:58:09
>>>> 56=X3S 115=AHPRO 116=AHPADMIN 128=AHINT 129=AHIADMIN 9426=VRES 15=GBP
>>>> 58=TEXT 117=first
>>>> response 131=VAL
>>>> Multiple 9400=* 9442=UT 9464=20090910-14:00:00 9469=Q 9477=11 9488=AHINT
>>>> 9490=AHPRO 9494=AGENCY
>>>> NO 9504=desig2 9450=3 9470=1 22=4 48=ISINLU898 9429=20091013-09:54:45
>>>> 9448=2432.45454 9493=fgfhgfhg 9470=2 22=4 48=ISINLU898
>>>> 9429=20091013-09:54:45 9448=2432.45454 9493=fgfhgfhg 9470=3 22=4
>>>> 48=ISINLU898 9429=20091013-09:54:45 9448=2432.45454 9493=fgfhgfhg
>>>> 9425=20091008-13:11:12 9452=20091008-13:11:16 9453=20091008-13:11:16
>>>> 9480=1.0~SHA-1~RSA~CN=EMX
>>>> Certificate Authority,OU=Certificate Authority,O=EMX Company
>>>>
>>>> Limited,C=GB~3ea639ba~3ee270f7e32929b5fb32eede09dd10c4f8e6809b83b7831165534be991e7845d6bfa7b6964f4336896d8f43e86e22d58b38362b6b6d096643d00351221df9b6d74ce9852689dc599c641182286de2b4ec8d47df6883d61a0664233daf34ec24026b985205ea2dbba5ca5856bb64ab911b8122c326bd1ccdd5d2b415b4d97ad94
>>>> 9481=20091008-13:11:12 9491=4003182 10=190 ";
>>>> String result = "";
>>>>
>>>> template.sendBody(record);
>>>>
>>>> resultEndpoint.expectedMessageCount(1);
>>>> // resultEndpoint.expectedBodiesReceived(result);
>>>> resultEndpoint.assertIsSatisfied();
>>>>
>>>> for (Exchange exch : resultEndpoint.getExchanges()) {
>>>> Object obj = exch.getIn().getBody();
>>>> System.out.println(">>> Class : " + obj.getClass().getName());
>>>> System.out.println(">>> CSV generated : " + obj.toString());
>>>> }
>>>>
>>>>
>>>>
>>>>
>>>> }
>>>>
>>>>
>>>>
>>>> /* �...@test
>>>> @DirtiesContext
>>>> public void testUnMarshallWithNullFields() throws Exception {
>>>>
>>>> // TODO add null fields
>>>> String record =
>>>> "8=FIX.4.1 9=89 35=U2 34=84 49=SERVER 52=20090630-10:29:25 56=X3S
>>>> 9426=TBKD 11=ORDER1 22=2 37=WWWWWW 48=ISIN24324343 54=1 58=TTT 67=1 68=1
>>>> 121=Y 152=33.43 173=TTTTTTT 174=TTTTTTTTTTT
>>>> 182=BIGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGGG 183=HHHHHH
>>>> 184=YYYYYYYYY 185=FFFFFFFFFFFFFF 9400=TTTTTTTTTTT 9401=1 9402=31.23 9403=1
>>>> 9404=TTT 9405=TTT 9406=TTT 9407=TTT 9408=TTT 9409=TTT 9410=TTT 9411=TTT
>>>> 9412=TTT 9413=N 9414=TTT 9415=TTT 9416=R 9417=USD 9418=DEM 9419=8.65
>>>> 9420=334 9422=M 9423=Y 9424=HJHJKHJKHJ 9428=20090303-12:25:55 9435=20080326
>>>> 9436=jhkjkj 9437=dddddddddd 9438=eeeeeeeeee 9439=1209 9440=AA 9441=8
>>>> 9442=PROTYP3 9443=1 9444=safdewfw 9449=fsgsg 9451=E 9455=EUR 9462=5 9468=?
>>>> 9471=433.443 9474=E 9475=Y 9482=fwrfw 9483=KKKKK 9484=KLKLKL 9485=JKIJKJKJ
>>>> 9488=ORIG1 9489=JJJJJ 9490=PRV03 9492=kjlklk 9494=AGENCY33 9495=23.18
>>>> 9491=TBKD-57765177 10=111 ";
>>>>
>>>> template.sendBody(record);
>>>>
>>>> resultEndpoint.expectedMessageCount(1);
>>>> resultEndpoint.assertIsSatisfied();
>>>>
>>>> List<Exchange> exchanges = resultEndpoint.getExchanges();
>>>>
>>>> for(Exchange exchange : exchanges) {
>>>>
>>>> models = (List<Map<String, Object>>) exchange.getIn().getBody();
>>>>
>>>> for (int i=0; i< models.size(); i++) {
>>>> model = models.get(i);
>>>> OutTbkdMessage tbkd =
>>>>
>>>> (OutTbkdMessage)model.get("com.xpectis.x3s.model.backoffice.emx.tbkd.out.OutTbkdMessage");
>>>> Assert.assertEquals(tbkd.getOrdUntNb(), null);
>>>> LOG.debug("Model : " + tbkd.toString());
>>>> }
>>>>
>>>>
>>>> }
>>>> }*/
>>>>
>>>> @Configuration
>>>> public static class ContextConfig extends SingleRouteCamelConfiguration
>>>> {
>>>> BindyKeyValuePairDataFormat emxBindyDataFormat = new
>>>>
>>>> BindyKeyValuePairDataFormat("com.xpectis.x3s.model.backoffice.emx.vres.out","com.xpectis.x3s.model.backoffice.emx.common");
>>>> BindyCsvDataFormat csvBindyDataFormat = new
>>>> BindyCsvDataFormat("com.xpectis.x3s.model.backoffice.emx.vres.in");
>>>>
>>>> @Override
>>>> @Bean
>>>> public RouteBuilder route() {
>>>> return new RouteBuilder() {
>>>> @Override
>>>> public void configure() {
>>>> from("direct:start")
>>>> .unmarshal(emxBindyDataFormat)
>>>> .process(new Processor() {
>>>>
>>>> public void process(Exchange exchange) throws
>>>> Exception {
>>>>
>>>> InVresMessage
>>>> inVresMessage = new InVresMessage();
>>>> List<Map<String, Object>> models = new
>>>> ArrayList<Map<String, Object>>();
>>>> List<Map<String, Object>> modelsReceived;
>>>> Map<String, Object> model = new
>>>> HashMap<String, Object>();
>>>>
>>>> modelsReceived =
>>>> (List<Map<String, Object>>) exchange.getIn().getBody();
>>>> OutVresMessage
>>>> outVresMessage = (OutVresMessage)
>>>>
>>>> modelsReceived.get(0).get("com.xpectis.x3s.model.backoffice.emx.vres.out.OutVresMessage");
>>>>
>>>>
>>>> PropertyUtils.copyProperties(inVresMessage, outVresMessage);
>>>>
>>>> model.put(inVresMessage.getClass().getName(), inVresMessage);
>>>> models.add( model
>>>> );
>>>>
>>>>
>>>> exchange.getIn().setBody(models);
>>>> }
>>>> }
>>>>
>>>> )
>>>> .marshal(csvBindyDataFormat)
>>>> .to("mock:result");
>>>> }
>>>> };
>>>> }
>>>> }
>>>>
>>>> }
>>>>
>>>>
>>>> Regards,
>>>>
>>>> Charles Moulliard
>>>> Senior Enterprise Architect
>>>> Apache Camel Committer
>>>>
>>>> *****************************
>>>> blog : http://cmoulliard.blogspot.com
>>>> twitter : http://twitter.com/cmoulliard
>>>>
>>>
>>>
>>>
>>
>>
>
