On Wed, Oct 7, 2015 at 12:43 AM, Yasassri Ratnayake <[email protected]> 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 <[email protected]> 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 <[email protected]> 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 >>> [email protected] >>> http://wso2.org/cgi-bin/mailman/listinfo/commits >>> >>> >>> On Tue, Oct 6, 2015 at 11:28 PM, Yasassri Ratnayake <[email protected]> >>> 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 <[email protected]> >>>> 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 : [email protected] >>>>> 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 : [email protected] >>> Blog : http://vitharana.org >>> Mobile : +1-812-360-5335 >>> >>> >> >> >> -- >> Ajith Vitharana. >> >> WSO2 Inc. - http://wso2.com >> Email : [email protected] >> 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 : [email protected] Blog : http://vitharana.org Mobile : +1-812-360-5335
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
