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. 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 <[email protected]> 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 <[email protected]> wrote: > >> >> >> 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 >> >> > > > -- > 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 > > -- 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
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
