Noted Malaka. I have created the jiras [1] & [2]. [1] - https://wso2.org/jira/browse/ESBJAVA-4646 [2] - https://wso2.org/jira/browse/ESBJAVA-4647
Thanks Kesavan Yogarajah Software Engineer Mobile :+94 (0) 779 758021 [email protected] WSO2, Inc. lean . enterprise . middleware On Thu, Jun 2, 2016 at 12:17 PM, Malaka Silva <[email protected]> wrote: > +1 Please create a jira and attach the fix. Better to fix it for all cases. > > ---------- Forwarded message ---------- > From: Kesavan Yogarajah <[email protected]> > Date: Thu, Jun 2, 2016 at 11:53 AM > Subject: Testing with ESB 5.0.0-BETA > To: Malaka Silva <[email protected]> > > > Hi Malaka, > > I have checked the rabbitmq inbound and some connectors with the ESB - > 5.0.0 BETA. I have found the following issues with rabbitmq inbound and > payload factory mediator. > > 1. In rabbitmq inbound, during the consumption of messages if an ill > formed message come intermittently the message consumption stopped with > [1].Ideally the consumption of messages should be continue.This can be > solved with [2]. > 2. When we using $ctx directly in the payload factory mediator if the > property is not set, it throws the null point exception [3].This can be > reproduced with proxy [4].Ideally it should give the response as [5]. > > > WDYT? > can I create jiras for above? > > [1] - > [2016-06-02 11:28:59,017] ERROR - TaskQuartzJobAdapter Error in executing > task: com.ctc.wstx.exc.WstxUnexpectedCharException: Unexpected character > '{' (code 123) in prolog; expected '<' > at [row,col {unknown-source}]: [1,1] > org.apache.axiom.om.OMException: > com.ctc.wstx.exc.WstxUnexpectedCharException: Unexpected character '{' > (code 123) in prolog; expected '<' > at [row,col {unknown-source}]: [1,1] > at > org.apache.axiom.om.impl.builder.StAXOMBuilder.next(StAXOMBuilder.java:296) > at > org.apache.axiom.om.impl.llom.OMDocumentImpl.getOMDocumentElement(OMDocumentImpl.java:109) > at > org.apache.axiom.om.impl.builder.StAXOMBuilder.getDocumentElement(StAXOMBuilder.java:570) > at > org.apache.axiom.om.impl.builder.StAXOMBuilder.getDocumentElement(StAXOMBuilder.java:566) > at > org.apache.axis2.builder.ApplicationXMLBuilder.processDocument(ApplicationXMLBuilder.java:81) > at > org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQInjectHandler.invoke(RabbitMQInjectHandler.java:107) > at > org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQConnectionConsumer.startConsumer(RabbitMQConnectionConsumer.java:169) > at > org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQConnectionConsumer.execute(RabbitMQConnectionConsumer.java:72) > at > org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQTask.taskExecute(RabbitMQTask.java:39) > at > org.wso2.carbon.inbound.endpoint.common.OneTimeTriggerInboundTask.execute(OneTimeTriggerInboundTask.java:46) > at > org.wso2.carbon.mediation.ntask.NTaskAdapter.execute(NTaskAdapter.java:98) > at > org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:67) > at org.quartz.core.JobRunShell.run(JobRunShell.java:213) > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > Caused by: com.ctc.wstx.exc.WstxUnexpectedCharException: Unexpected > character '{' (code 123) in prolog; expected '<' > at [row,col {unknown-source}]: [1,1] > at > com.ctc.wstx.sr.StreamScanner.throwUnexpectedChar(StreamScanner.java:639) > at > com.ctc.wstx.sr.BasicStreamReader.nextFromProlog(BasicStreamReader.java:2052) > at com.ctc.wstx.sr.BasicStreamReader.next(BasicStreamReader.java:1134) > at > org.apache.axiom.util.stax.wrapper.XMLStreamReaderWrapper.next(XMLStreamReaderWrapper.java:225) > at > org.apache.axiom.util.stax.dialect.DisallowDoctypeDeclStreamReaderWrapper.next(DisallowDoctypeDeclStreamReaderWrapper.java:34) > at > org.apache.axiom.om.impl.builder.StAXOMBuilder.parserNext(StAXOMBuilder.java:681) > at > org.apache.axiom.om.impl.builder.StAXOMBuilder.next(StAXOMBuilder.java:214) > ... 17 more > > [2] - > diff --git > a/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/rabbitmq/RabbitMQConnectionConsumer.java > b/components/inbound-e > index d6c8ea5..fd818d0 100644 > --- > a/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/rabbitmq/RabbitMQConnectionConsumer.java > +++ > b/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/rabbitmq/RabbitMQConnectionConsumer.java > @@ -18,7 +18,14 @@ > > package org.wso2.carbon.inbound.endpoint.protocol.rabbitmq; > > -import com.rabbitmq.client.*; > +import com.rabbitmq.client.AMQP; > +import com.rabbitmq.client.Channel; > +import com.rabbitmq.client.Connection; > +import com.rabbitmq.client.ConsumerCancelledException; > +import com.rabbitmq.client.ShutdownSignalException; > +import com.rabbitmq.client.QueueingConsumer; > + > +import org.apache.axiom.om.OMException; > import org.apache.commons.lang.StringUtils; > import org.apache.commons.logging.Log; > import org.apache.commons.logging.LogFactory; > @@ -76,6 +83,8 @@ public class RabbitMQConnectionConsumer { > " was disconnected", sse); > waitForConnection(); > } > + } catch (OMException e){ > + log.error("Invalid Message Format while consuming the > message", e); > } catch (IOException e) { > log.error("RabbitMQ Listener of the inbound " + > inboundName + > " was disconnected", e); > > [3] > [2016-06-02 11:47:43,471] ERROR - SequenceMediator Runtime error occurred > while mediating the message > java.lang.NullPointerException > at > org.apache.synapse.mediators.transform.PayloadFactoryMediator.replaceCTX(PayloadFactoryMediator.java:236) > at > org.apache.synapse.mediators.transform.PayloadFactoryMediator.regexTransformCTX(PayloadFactoryMediator.java:213) > at > org.apache.synapse.mediators.transform.PayloadFactoryMediator.mediate(PayloadFactoryMediator.java:155) > at > org.apache.synapse.mediators.transform.PayloadFactoryMediator.mediate(PayloadFactoryMediator.java:104) > at > org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:97) > at > org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:54) > at > org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java:164) > at > org.apache.synapse.core.axis2.ProxyServiceMessageReceiver.receive(ProxyServiceMessageReceiver.java:215) > at org.apache.axis2.engine.AxisEngine.receive(AxisEngine.java:180) > at > org.apache.synapse.transport.passthru.ServerWorker.processEntityEnclosingRequest(ServerWorker.java:398) > at > org.apache.synapse.transport.passthru.ServerWorker.run(ServerWorker.java:145) > at > org.apache.axis2.transport.base.threads.NativeWorkerPool$1.run(NativeWorkerPool.java:172) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > [2016-06-02 11:47:43,474] INFO - LogMediator To: > /services/11test.11testHttpSoap12Endpoint, WSAction: urn:mediate, > SOAPAction: urn:mediate, MessageID: > urn:uuid:f933dae8-06ed-42a2-b008-8b829ebbb65e, Direction: request, MESSAGE > = Executing default 'fault' sequence, ERROR_CODE = 0, ERROR_MESSAGE = > Runtime error occurred while mediating the message, Envelope: <?xml > version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv=" > http://www.w3.org/2003/05/soap-envelope > "><soapenv:Body/></soapenv:Envelope> > > > [4] > > <?xml version="1.0" encoding="UTF-8"?> > <proxy xmlns="http://ws.apache.org/ns/synapse"; > name="11test" > transports="http,https" > statistics="disable" > trace="disable" > startOnLoad="true"> > <target> > <inSequence> > <property name="param1" value="111111"/> > <property name="param2" value="222222"/> > <payloadFactory media-type="xml"> > <format> > <urn:elts xmlns:urn="wso2.esb.test"> > <urn:elt1>$1</urn:elt1> > <urn:elt2>$ctx:param2</urn:elt2> > <urn:elt3>$2</urn:elt3> > <urn:elt4>$ctx:param4</urn:elt4> > </urn:elts> > </format> > <args> > <arg evaluator="xml" expression="get-property('param1')"/> > <arg evaluator="xml" expression="get-property('param3')"/> > </args> > </payloadFactory> > <log level="custom"/> > <respond/> > </inSequence> > <outSequence> > <log/> > <send/> > </outSequence> > </target> > <description/> > </proxy> > > [5] - > <urn:elts xmlns:urn="wso2.esb.test"> > <urn:elt1>111111</urn:elt1> > <urn:elt2>222222</urn:elt2> > <urn:elt3/> > <urn:elt4/> > </urn:elts> > > > Thanks > > Kesavan Yogarajah > Software Engineer > Mobile :+94 (0) 779 758021 > [email protected] > WSO2, Inc. > lean . enterprise . middleware > > > > -- > > Best Regards, > > Malaka Silva > Senior Tech Lead > M: +94 777 219 791 > Tel : 94 11 214 5345 > Fax :94 11 2145300 > Skype : malaka.sampath.silva > LinkedIn : http://www.linkedin.com/pub/malaka-silva/6/33/77 > Blog : http://mrmalakasilva.blogspot.com/ > > WSO2, Inc. > lean . enterprise . middleware > http://www.wso2.com/ > http://www.wso2.com/about/team/malaka-silva/ > <http://wso2.com/about/team/malaka-silva/> > https://store.wso2.com/store/ > > Save a tree -Conserve nature & Save the world for your future. Print this > email only if it is absolutely necessary. > > _______________________________________________ > Dev mailing list > [email protected] > http://wso2.org/cgi-bin/mailman/listinfo/dev > >
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
