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
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
