Hi Ravindra,
On Mon, Oct 12, 2015 at 1:07 AM, Ravindra Ranwala <ravin...@wso2.com> wrote: > Hi Ajith, > > This is not a bug in the MP, rather it is a configuration related issue. > Here a getQuote request is sent which is a classical IN-OUT scenario. > Therefore you are getting a response. If you are getting a response you > need to define a reply sequence at the MP. Otherwise the MP has no way of > handling the response. > Thank you for the explanation. But this information is not available in the doc [1]. Could you please document , then resolve the tickets ? Reply sequence name (message.processor.reply.sequence) The name of the sequence where the message reply should be sent. No [1] https://docs.wso2.com/display/ESB490/Scheduled+Message+Forwarding+Processor -Ajith > Please define a simple reply sequence and point the MP to that. Also > create a Documentation issue to include it in our documentation [1]. Also I > guess we can resolve the jira issue [2] since it is not a bug in ESB, > rather a documentation issue. > > A sample reply sequence config is given below. > > > <?xml version="1.0" encoding="UTF-8"?> > <sequence xmlns="http://ws.apache.org/ns/synapse"; name="replySequence"> > <log level="full"> > <property name="REPLY" value="MESSAGE"/> > </log> > <drop/> > </sequence> > > > > > > > [1] https://docs.wso2.com/display/IntegrationPatterns/Durable+Subscriber > [2] https://wso2.org/jira/browse/ESBJAVA-4263 > > > Thanks & Regards, > > On Sun, Oct 11, 2015 at 3:26 AM, Ajith Vitharana <aji...@wso2.com> wrote: > >> Hi All. >> >> Created JIRAs for above issues. >> >> [1] https://wso2.org/jira/browse/DOCUMENTATION-2524 >> [2] https://wso2.org/jira/browse/ESBJAVA-4263 >> >> -Ajith >> >> On Wed, Oct 7, 2015 at 12:48 AM, Ajith Vitharana <aji...@wso2.com> wrote: >> >>> >>> >>> On Wed, Oct 7, 2015 at 12:43 AM, Yasassri Ratnayake <yasas...@wso2.com> >>> wrote: >>> >>>> According to [1] "*The deactivate sequence that will be executed when >>>> the processor is deactivated automatically. Automatic deactivation occurs >>>> when the maximum delivery attempts is exceeded and the Drop message after >>>> maximum delivery attempts parameter is disabled.*" >>>> >>>> [1] - https://docs.wso2.com/display/ESB490/Message+Forwarding+Processor >>>> >>> >>> >>> The backed is available *BEFORE* exceed the max delivery attempts. But >>> still message processor going to deactivate ? >>> >>> -Ajith >>> >>>> >>>> On Wed, Oct 7, 2015 at 10:06 AM, Ajith Vitharana <aji...@wso2.com> >>>> wrote: >>>> >>>>> Other issue is, >>>>> >>>>> 1. According to the sample I'm shutting down the backend-1 and send a >>>>> request. >>>>> 2. Now I can see the message store has one message. >>>>> 3. Before 50 delivery attempts , start the backend-1 >>>>> 4. Now I can see the message processor executed and message delivered >>>>> to backed-1 >>>>> >>>>> But just after sending the message, the message processor going to >>>>> deactivate state and printing following exception. >>>>> >>>>> [2015-10-07 00:25:03,987] WARN - ForwardingService Failed to send the >>>>> message through the fault sequence. Sequence name does not Exist. >>>>> *[2015-10-07 00:25:05,335] WARN - ForwardingService Failed to send >>>>> the message through the deactivate sequence. Sequence name does not >>>>> Exist.* >>>>> [2015-10-07 00:25:05,340] INFO - ScheduledMessageProcessor >>>>> Successfully deactivated the message processor [send_pending_message] >>>>> *[2015-10-07 00:25:05,341] ERROR - ForwardingService Failed to send >>>>> the out message. Reply sequence does not Exist. Deactivated the message >>>>> processor* >>>>> >>>>> >>>>> 1. According to the WARN log , what is the deactivate sequence should >>>>> define ? >>>>> 2. Why message processor is deactivate just after sending message to >>>>> back end ? >>>>> >>>>> -Ajith >>>>> >>>>> >>>>> On Tue, Oct 6, 2015 at 11:39 PM, Ajith Vitharana <aji...@wso2.com> >>>>> wrote: >>>>> >>>>>> Hi Yasassri. >>>>>> >>>>>> Yes. According to the carbon commits it has renamed. Then those >>>>>> configs never tested after 2012 :) >>>>>> >>>>>> [1] https://wso2.org/jira/browse/CARBON-13114 >>>>>> >>>>>> -Ajith >>>>>> >>>>>> >>>>>> Author: ishan >>>>>> Date: Fri Jun 15 02:00:53 2012 >>>>>> New Revision: 130164 >>>>>> URL: http://wso2.org/svn/browse/wso2?view=rev&revision=130164 >>>>>> >>>>>> Log: >>>>>> Fixing CARBON-13114 with the patch of CharithaM. >>>>>> >>>>>> Modified: >>>>>> carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/org/wso2/carbon/message/processor/ui/i18n/ >>>>>> Resources.properties >>>>>> carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/index.jsp >>>>>> carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/manageMessageForwardingProcessor.jsp >>>>>> >>>>>> Modified: carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/org/wso2/carbon/message/processor/ui/i18n/ >>>>>> Resources.properties >>>>>> URL: >>>>>> http://wso2.org/svn/browse/wso2/carbon/platform/trunk/components/mediation/message-processor/org.wso2.carbon.message.processor.ui/src/main/resources/org/wso2/carbon/message/processor/ui/i18n/Resources.properties?rev=130164&r1=130163&r2=130164&view=diff >>>>>> ============================================================ >>>>>> ================== >>>>>> --- carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/org/wso2/carbon/message/processor/ui/i18n/Resources.properties >>>>>> (original) >>>>>> +++ carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/org/wso2/carbon/message/processor/ui/i18n/Resources.properties >>>>>> Fri Jun 15 02:00:53 2012 >>>>>> @@ -24,7 +24,9 @@ >>>>>> size=Size >>>>>> action=Actions >>>>>> deactivate=Deactivate >>>>>> -activate=activate >>>>>> +activate=Activate >>>>>> +inactive=Inactive >>>>>> +active=Active >>>>>> no.messageProcessors.are.currently.defined=No Message Processors >>>>>> are currently defined. >>>>>> message.Processor= Message Processor >>>>>> name=Name >>>>>> @@ -104,7 +106,7 @@ >>>>>> message.sampling.processor.parameters=Message Sampling Processor >>>>>> Parameters >>>>>> message.context.properties=Message Context Properties >>>>>> interval=Message retry interval (Millis) >>>>>> >>>>>> >>>>>> *-max.deliver.attempts=Maximum delivery >>>>>> attempts+max.delivery.attempts=Maximum delivery attempts* >>>>>> axis2.repo=Axis2 Client repository >>>>>> axis2.config=Axis2 Configuration >>>>>> message.processor.reply.sequence=Reply sequence name >>>>>> @@ -112,4 +114,4 @@ >>>>>> quartz.conf=Quartz configuration file path >>>>>> cronExpression=Cron Expression >>>>>> target.endpoint=Address Endpoint name >>>>>> -out_only=Out-only message >>>>>> \ No newline at end of file >>>>>> +out_only=Out-only message >>>>>> >>>>>> Modified: carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/index.jsp >>>>>> URL: >>>>>> http://wso2.org/svn/browse/wso2/carbon/platform/trunk/components/mediation/message-processor/org.wso2.carbon.message.processor.ui/src/main/resources/web/message_processor/index.jsp?rev=130164&r1=130163&r2=130164&view=diff >>>>>> ============================================================ >>>>>> ================== >>>>>> --- carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/index.jsp (original) >>>>>> +++ carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/index.jsp Fri Jun 15 02:00:53 >>>>>> 2012 >>>>>> @@ -290,11 +290,14 @@ >>>>>> id="delete_link" class="icon-link" >>>>>> style="background-image:url(.. >>>>>> /admin/images/delete.gif);"><fmt:message >>>>>> key="delete"/></a> >>>>>> - <a href="#" >>>>>> - onclick="deactivateRow(this. >>>>>> parentNode.parentNode.rowIndex)" >>>>>> - id="deactivate_link" class="icon-link" >>>>>> - style="background-image:url(.. >>>>>> /message_processor/images/deactivate.gif);"><fmt:message >>>>>> - key="deactivate"/></a> >>>>>> + <span class="icon-text" >>>>>> style="background-image:url(../message_processor/images/ >>>>>> activate.gif);"> >>>>>> + <fmt:message key="active"/> [</span> >>>>>> + <a href="#" class="icon-link" id="deactivate_link" >>>>>> + style="background-image:none !important; >>>>>> margin-left: 0px !important; padding-left: 0px !important;" >>>>>> + onclick="deactivateRow(this. >>>>>> parentNode.parentNode.rowIndex)"><fmt:message key="deactivate"/></a> >>>>>> + <span class="icon-text" >>>>>> + style="background-image:none !important; >>>>>> margin-left: 0px !important; padding-left: 0px !important;">]</span> >>>>>> + >>>>>> </td> >>>>>> <% >>>>>> } else if ("Scheduled Message Forwarding Processor". >>>>>> @@ -308,11 +311,14 @@ >>>>>> id="delete_link" class="icon-link" >>>>>> style="background-image:url(.. >>>>>> /admin/images/delete.gif);"><fmt:message >>>>>> key="delete"/></a> >>>>>> - <a href="#" >>>>>> - onclick="activateRow(this.parentNode.parentNode. >>>>>> rowIndex,true)" >>>>>> - id="activate_link" class="icon-link" >>>>>> - style="background-image:url(.. >>>>>> /message_processor/images/activate.gif);"><fmt:message >>>>>> - key="activate"/></a> >>>>>> + <span class="icon-text" >>>>>> style="background-image:url(../message_processor/images/ >>>>>> deactivate.gif);"> >>>>>> + <fmt:message key="inactive"/> [</span> >>>>>> + <a href="#" class="icon-link" id="activate_link" >>>>>> + style="background-image:none !important; >>>>>> margin-left: 0px !important; padding-left: 0px !important;" >>>>>> + >>>>>> onclick="activateRow(this.parentNode.parentNode.rowIndex,true)"><fmt:message >>>>>> key="activate"/></a> >>>>>> + <span class="icon-text" >>>>>> + style="background-image:none !important; >>>>>> margin-left: 0px !important; padding-left: 0px !important;">]</span> >>>>>> + >>>>>> </td> >>>>>> <% >>>>>> } else if ("Message Sampling Processor". >>>>>> @@ -326,11 +332,15 @@ >>>>>> id="delete_link" class="icon-link" >>>>>> style="background-image:url(.. >>>>>> /admin/images/delete.gif);"><fmt:message >>>>>> key="delete"/></a> >>>>>> - <a href="#" >>>>>> - onclick="activateRow(this.parentNode.parentNode. >>>>>> rowIndex)" >>>>>> - id="activate_link" class="icon-link" >>>>>> - style="background-image:url(.. >>>>>> /message_processor/images/activate.gif);"><fmt:message >>>>>> - key="activate"/></a> >>>>>> + <span class="icon-text" >>>>>> + style="background-image:url(.. >>>>>> /message_processor/images/deactivate.gif);"> >>>>>> + <fmt:message key="inactive"/> [</span> >>>>>> + <a href="#" class="icon-link" id="activate_link" >>>>>> + style="background-image:none !important; >>>>>> margin-left: 0px !important; padding-left: 0px !important;" >>>>>> + >>>>>> onclick="activateRow(this.parentNode.parentNode.rowIndex)"><fmt:message >>>>>> key="activate"/></a> >>>>>> + <span class="icon-text" >>>>>> + style="background-image:none !important; >>>>>> margin-left: 0px !important; padding-left: 0px !important;">]</span> >>>>>> + >>>>>> </td> >>>>>> <%} else { %> >>>>>> <td><a onclick="editRow('<%= type%>', >>>>>> this.parentNode.parentNode.rowIndex)" href="#" >>>>>> @@ -414,4 +424,4 @@ >>>>>> alternateTableRows('myTable', 'tableEvenRow', 'tableOddRow'); >>>>>> alternateTableRows('dlcTable', 'tableEvenRow', 'tableOddRow'); >>>>>> </script> >>>>>> -</fmt:bundle> >>>>>> \ No newline at end of file >>>>>> +</fmt:bundle> >>>>>> >>>>>> Modified: carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/manageMessageForwardingProcessor.jsp >>>>>> URL: >>>>>> http://wso2.org/svn/browse/wso2/carbon/platform/trunk/components/mediation/message-processor/org.wso2.carbon.message.processor.ui/src/main/resources/web/message_processor/manageMessageForwardingProcessor.jsp?rev=130164&r1=130163&r2=130164&view=diff >>>>>> ============================================================ >>>>>> ================== >>>>>> --- carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/manageMessageForwardingProcessor.jsp >>>>>> (original) >>>>>> +++ carbon/platform/trunk/components/mediation/message- >>>>>> processor/org.wso2.carbon.message.processor.ui/src/main/ >>>>>> resources/web/message_processor/manageMessageForwardingProcessor.jsp >>>>>> Fri Jun 15 02:00:53 2012 >>>>>> @@ -92,7 +92,7 @@ >>>>>> >>>>>> function addServiceParams() { >>>>>> addServiceParameter("interval", document.getElementById(' >>>>>> retry_interval').value); >>>>>> - addServiceParameter("max.deliver.attempts", >>>>>> document.getElementById('max_delivery_attempts').value); >>>>>> + addServiceParameter("max.delivery.attempts", >>>>>> document.getElementById('max_delivery_attempts').value); >>>>>> addServiceParameter("axis2.repo", document.getElementById(' >>>>>> axis2_repo').value); >>>>>> addServiceParameter("axis2.config", >>>>>> document.getElementById('axis2_config').value); >>>>>> addServiceParameter("message.processor.reply.sequence", >>>>>> document.getElementById('message_processor_reply_sequence').value); >>>>>> @@ -292,10 +292,10 @@ >>>>>> </td> >>>>>> </tr> >>>>>> <tr> >>>>>> - <td><fmt:message key="max.deliver.attempts >>>>>> "/></td> >>>>>> + <td><fmt:message key="max.delivery.attempts >>>>>> "/></td> >>>>>> <td><input type="text" >>>>>> id="max_delivery_attempts" name="max_delivery_attempts" >>>>>> value="<%=((null!=processorData)&& >>>>>> processorData.getParams() != null >>>>>> - && >>>>>> !processorData.getParams().isEmpty()&&(processorData. >>>>>> getParams().get("max.deliver.attempts")!=null))? >>>>>> processorData.getParams().get("max.deliver.attempts"):""%>" >>>>>> + && >>>>>> !processorData.getParams().isEmpty()&&(processorData. >>>>>> getParams().get("max.delivery.attempts")!=null))? >>>>>> processorData.getParams().get("max.delivery.attempts"):""%>" >>>>>> /> >>>>>> </td> >>>>>> </tr> >>>>>> _______________________________________________ >>>>>> Commits mailing list >>>>>> comm...@wso2.org >>>>>> http://wso2.org/cgi-bin/mailman/listinfo/commits >>>>>> >>>>>> >>>>>> On Tue, Oct 6, 2015 at 11:28 PM, Yasassri Ratnayake < >>>>>> yasas...@wso2.com> wrote: >>>>>> >>>>>>> Hi Ajith, >>>>>>> >>>>>>> It seems the configs are not correct in the sample, Also in your >>>>>>> second step the parameter name is *<parameter >>>>>>> name="max.delivery.attempts">4</parameter> *which is correct, but >>>>>>> in the sample the Property is given *<parameter >>>>>>> name="max.deliver.attempts">50</parameter>. *This must be causing >>>>>>> the inconsistent behavior. >>>>>>> >>>>>>> With Regards, >>>>>>> >>>>>>> On Wed, Oct 7, 2015 at 8:27 AM, Ajith Vitharana <aji...@wso2.com> >>>>>>> wrote: >>>>>>> >>>>>>>> Hi All, >>>>>>>> >>>>>>>> I updated source view from the configuration mentioned in sample >>>>>>>> [1]. >>>>>>>> >>>>>>>> i) When I double check the message processor configs from source >>>>>>>> view, I noticed same config as the sample (expected behavior). >>>>>>>> >>>>>>>> <messageProcessor >>>>>>>> class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessor" >>>>>>>> messageStore="*pending_subscriptions*" name="send_pending_message" >>>>>>>> targetEndpoint="DurableSubscriberEndpoint"> >>>>>>>> <parameter name="interval">1000</parameter> >>>>>>>> <parameter name="throttle">false</parameter> >>>>>>>> <parameter >>>>>>>> name="target.endpoint">DurableSubscriberEndpoint</parameter> >>>>>>>> * <parameter name="max.deliver.attempts">50</parameter>* >>>>>>>> </messageProcessor> >>>>>>>> >>>>>>>> ii) When I go to the "Message Processors" UI and edit the config >>>>>>>> (wrong configurations) >>>>>>>> >>>>>>>> <messageProcessor name="send_pending_message" >>>>>>>> class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessor" >>>>>>>> targetEndpoint="DurableSubscriberEndpoint" messageStore=" >>>>>>>> *pending_subscriptions*" xmlns="http://ws.apache.org/ns/synapse";> >>>>>>>> <parameter name="interval">1000</parameter> >>>>>>>> <parameter name="client.retry.interval">1000</parameter> >>>>>>>> * <parameter name="max.delivery.attempts">4</parameter>* >>>>>>>> <parameter name="is.active">true</parameter> >>>>>>>> <parameter name="max.delivery.drop">Disabled</parameter> >>>>>>>> <parameter name="member.count">1</parameter> >>>>>>>> </messageProcessor> >>>>>>>> >>>>>>>> iii) According to the sample , I noticed the message processor is >>>>>>>> deactivating after the 4 attempts, that means the second config >>>>>>>> executing >>>>>>>> at mediation. >>>>>>>> >>>>>>>> >>>>>>>> iv) When I check the file >>>>>>>> in synapse-configs/default/message-processors that is updated with my >>>>>>>> new >>>>>>>> configs. >>>>>>>> >>>>>>>> <?xml version="1.0" encoding="UTF-8"?> >>>>>>>> <messageProcessor xmlns="http://ws.apache.org/ns/synapse"; >>>>>>>> >>>>>>>> class="org.apache.synapse.message.processor.impl.forwarder.ScheduledMessageForwardingProcessor" >>>>>>>> name="*send_pending_message*" >>>>>>>> targetEndpoint="DurableSubscriberEndpoint" >>>>>>>> messageStore="pending_subscriptions"> >>>>>>>> <parameter name="interval">1000</parameter> >>>>>>>> <parameter name="throttle">false</parameter> >>>>>>>> <parameter >>>>>>>> name="target.endpoint">DurableSubscriberEndpoint</parameter> >>>>>>>> * <parameter name="max.deliver.attempts">50</parameter>* >>>>>>>> </messageProcessor> >>>>>>>> >>>>>>>> >>>>>>>> [1] >>>>>>>> https://docs.wso2.com/display/IntegrationPatterns/Durable+Subscriber >>>>>>>> >>>>>>>> -- >>>>>>>> Ajith Vitharana. >>>>>>>> >>>>>>>> WSO2 Inc. - http://wso2.com >>>>>>>> Email : aji...@wso2.com >>>>>>>> Blog : http://vitharana.org >>>>>>>> Mobile : +1-812-360-5335 >>>>>>>> >>>>>>>> >>>>>>> >>>>>>> >>>>>>> -- >>>>>>> Yasassri Ratnayake >>>>>>> Software Engineer - QA >>>>>>> WSO2 Inc ; http://wso2.com >>>>>>> lean.enterprise.middleware >>>>>>> *Mobile : +94715933168 <%2B94715933168>* >>>>>>> *Blogs : http://yasassriratnayake.blogspot.com >>>>>>> <http://yasassriratnayake.blogspot.com/>* >>>>>>> * http://wso2logs.blogspot.com >>>>>>> <http://wso2logs.blogspot.com>* >>>>>>> >>>>>> >>>>>> >>>>>> >>>>>> -- >>>>>> Ajith Vitharana. >>>>>> >>>>>> WSO2 Inc. - http://wso2.com >>>>>> Email : aji...@wso2.com >>>>>> Blog : http://vitharana.org >>>>>> Mobile : +1-812-360-5335 >>>>>> >>>>>> >>>>> >>>>> >>>>> -- >>>>> Ajith Vitharana. >>>>> >>>>> WSO2 Inc. - http://wso2.com >>>>> Email : aji...@wso2.com >>>>> Blog : http://vitharana.org >>>>> Mobile : +1-812-360-5335 >>>>> >>>>> >>>> >>>> >>>> -- >>>> Yasassri Ratnayake >>>> Software Engineer - QA >>>> WSO2 Inc ; http://wso2.com >>>> lean.enterprise.middleware >>>> *Mobile : +94715933168 <%2B94715933168>* >>>> *Blogs : http://yasassriratnayake.blogspot.com >>>> <http://yasassriratnayake.blogspot.com/>* >>>> * http://wso2logs.blogspot.com >>>> <http://wso2logs.blogspot.com>* >>>> >>> >>> >>> >>> -- >>> Ajith Vitharana. >>> >>> WSO2 Inc. - http://wso2.com >>> Email : aji...@wso2.com >>> Blog : http://vitharana.org >>> Mobile : +1-812-360-5335 >>> >>> >> >> >> -- >> Ajith Vitharana. >> >> WSO2 Inc. - http://wso2.com >> Email : aji...@wso2.com >> Blog : http://vitharana.org >> Mobile : +1-812-360-5335 >> >> >> _______________________________________________ >> Dev mailing list >> Dev@wso2.org >> http://wso2.org/cgi-bin/mailman/listinfo/dev >> >> > > > -- > Ravindra Ranwala > Software Engineer > WSO2, Inc: http://wso2.com > <http://www.google.com/url?q=http%3A%2F%2Fwso2.com&sa=D&sntz=1&usg=AFQjCNEZvyc0uMD1HhBaEGCBxs6e9fBObg> > Mobile: +94714198770 > > -- Ajith Vitharana. WSO2 Inc. - http://wso2.com Email : aji...@wso2.com Blog : http://vitharana.org Mobile : +1-812-360-5335
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
