+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
