Vasumathi, Could you try enabling DEBUG logging for the container itself as explained in http://servicemix.apache.org/how-do-i-change-the-logging.html?
Regards, Gert Vanthienen ------------------------ Open Source SOA: http://fusesource.com Blog: http://gertvanthienen.blogspot.com/ 2009/2/5 Vasumathi, Rajamarthandan <[email protected]>: > Hi Gert Vanthienen > > Thanks for your reply. I had debug statements, just removed them before > submitting the code to forum. Please find the bean method with debug > statements and the console displaying/printing the statement values. > > It is executing onMessageExchange successfully while the control > returning back from onMessageExchange method to router the router occurs > (I guess). > > Please help me to solve this issue. I am struggling for the past four > days with the same issue. > > Bean method > ----------- > > public void onMessageExchange(MessageExchange exchange) > throws MessagingException { > > if (exchange.getStatus() == ExchangeStatus.ACTIVE) { > NormalizedMessage normalizedMessage =null; > NormalizedMessage normalizedMessageOut=null; > normalizedMessage = exchange.getMessage("in"); > normalizedMessageOut= exchange.createMessage(); > String outMessage = > processXml(normalizedMessage); > System.out.println("after processXml11111" + > outMessage); > normalizedMessageOut.setContent(new > StringSource(outMessage)); > System.out.println("set > content"+normalizedMessageOut.getContent().toString()); > exchange.setMessage(normalizedMessageOut, > "out"); > exchange.setStatus(ExchangeStatus.ACTIVE); > System.out.println("before sending"); > channel.send(exchange); > System.out.println("after sending"); > } > } > private String processXml(NormalizedMessage normalizedMessage) > throws MessagingException { > SourceTransformer sourceTransformer = new SourceTransformer(); > String inMessage = ""; > try { > inMessage = sourceTransformer.contentToString(normalizedMessage); > } catch (Exception e) { > throw new MessagingException(e); > } > System.out.println("input"+inMessage); > System.out.println("coreMessage from Service1"+coreMessage); > String outMessage ="<response1>" + coreMessage + "</response1>"; > System.out.println("11111111"); > System.out.println("## Out Message: " + outMessage); > return outMessage; > } > } > > Server console output > --------------------- > > input<?xml version="1.0" encoding="UTF-8"?><input2>Tesing Content Based > Rounter > 2222</input2> > coreMessage from Service1<input2>Tesing Content Based Rounter > 2222</input2> > 11111111 > ## Out Message: <response1><input2>Tesing Content Based Rounter > 2222</input2></r > esponse1> > after processXml11111<response1><input2>Tesing Content Based Rounter > 2222</input > 2></response1> > set contentStringSource[<response1><input2>Tesing Content Based Rounter > 2222</in > put2></response1>] > before sending > after sending > [Fatal Error] :-1:-1: Premature end of file. > [Fatal Error] :-1:-1: Premature end of file. > ERROR - EIPComponent - Error processing exchange > InOnly[ > id: ID:10.102.11.29-11f46231bc3-11:2 > status: Active > role: provider > service: {http://test}MyStaticRoutingSlip1Service > endpoint: myStaticRoutingSlip1Su > operation: {http://test}onMessage > in: Unable to display: org.xml.sax.SAXParseException: Premature end of > file. > ] > org.xml.sax.SAXParseException: Premature end of file. > > Please help me to solve this issue. I am struggling for the past four > days with the same issue. > > Thanks > Vasumathi > > > -----Original Message----- > From: Gert Vanthienen [mailto:[email protected]] > Sent: Thursday, February 05, 2009 7:46 AM > To: [email protected] > Subject: Re: Unable to display: org.xml.sax.SAXParseException: Premature > end of file > > Vasumathi, > > This is probably caused by something consuming a StreamSource or > StaxSource before your service touches it. To make sure that this is > the cause, could you try enabling DEBUG logging because this should > 'solve' the issue then? > > Once we are sure that this is the cause of the problem, we should try to > modify the bean method so that it converts the source into a re-readable > source type before actually processing it. Our MessageUtil class has a > method named enableContentRereadability() that was created exactly for > this purpose. > > Regards, > > Gert Vanthienen > ------------------------ > Open Source SOA: http://fusesource.com > Blog: http://gertvanthienen.blogspot.com/ > > > > 2009/2/5 Vasumathi, Rajamarthandan > <[email protected]>: >> Hi All, >> >> I am new to service Mix and JBI. I am getting the below error while >> executing a content enricher EIP. The service Mix version I am using >> is 3.3.1.3. I am using In-Only exchange pattern. >> >> Overall flow goes like this >> >> JMS BC -> Content Enricher EIP -> Service Unit(Temporarily using a >> Single Service Unit) >> >> Error I am facing >> >> [Fatal Error] :-1:-1: Premature end of file. >> [Fatal Error] :-1:-1: Premature end of file. >> ERROR - EIPComponent - Error processing exchange >> InOnly[ >> id: ID:10.102.11.29-11f46231bc3-11:0 >> status: Active >> role: provider >> service: {http://test}MyStaticRoutingSlip1Service >> endpoint: myStaticRoutingSlip1Su >> operation: {http://test}onMessage >> in: Unable to display: org.xml.sax.SAXParseException: Premature end >> of file ] >> org.xml.sax.SAXParseException: Premature end of file. >> >> Please find the code >> >> JMS BC >> ------- >> >> <beans xmlns:jms="http://servicemix.apache.org/jms/1.0"; >> xmlns:test="http://test"; xmlns:amq="http://activemq.org/config/1.0";> >> <jms:endpoint service="test:MyJmsQueueTest" endpoint="jmsQueue" >> targetService="test:MyStaticRoutingSlip1Service" >> targetEndpoint="myStaticRoutingSlip1Su" >> role="consumer" destinationStyle="queue" >> jmsProviderDestinationName="myJmsQueueTest" >> defaultMep="http://www.w3.org/2004/08/wsdl/in-only"; >> defaultOperation="test:onMessage" >> connectionFactory="#connectionFactory"> >> </jms:endpoint> >> <amq:connectionFactory id="connectionFactory" >> brokerURL="tcp://localhost:61616" /> >> </beans> >> >> Cotent Enricher EIP >> ------------------- >> <beans xmlns:eip="http://servicemix.apache.org/eip/1.0"; >> xmlns:test="http://test";> >> <eip:content-enricher service="test:MyStaticRoutingSlip1Service" >> endpoint="myStaticRoutingSlip1Su"> >> <eip:enricherTarget> >> <eip:exchange-target service="test:MyS1PojoService"/> >> </eip:enricherTarget> >> >> </eip:content-enricher> >> </beans> >> >> Service Unit - Pojo code >> -------------------------- >> >> public void onMessageExchange(MessageExchange exchange) { if >> (exchange.getStatus() == ExchangeStatus.ACTIVE) { >> >> NormalizedMessage normalizedMessage =null; >> NormalizedMessage normalizedMessageOut=null; >> normalizedMessage = exchange.getMessage("in"); >> normalizedMessageOut= exchange.createMessage(); >> String outMessage = processXml(normalizedMessage); >> normalizedMessageOut.setContent(new StringSource(outMessage)); >> exchange.setMessage(normalizedMessageOut, "out"); >> exchange.setStatus(ExchangeStatus.ACTIVE); >> channel.send(exchange); >> >> } >> } >> >> I am struggling for the past four days with this issue. Please help me > >> to solve the issue. >> >> Thanks >> Vasumathi >> >> >> >> >> >> >> >> >
