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