rabbitmq - WSO2 ESB: Address endpoint does not resume sending after backends recovery -

-

i using wso2 esb rabbitmq, have 2 proxy services:

  • amqpproducersample, receives messages via http transport , send rabbitmq queue
  • amqpproxy works consumer rabbitmq queue (via rabbitmq transport), consumed messages send http endpoint sampleendpoint

everything works fine except 1 scenario:

  1. my backend service set in sampleendpoint goes down.

  2. new messages arrives , published via amqpproducersample, delivery fails (that expected because backend down). in console can see: 

    warn - connectcallback connection refused or failed : mfb.localhost/127.0.0.1:80 warn - faulthandler error_code : 101503 warn - faulthandler error_message : error connecting end warn - faulthandler error_detail : error connecting end warn - faulthandler error_exception : null warn - faulthandler faulthandler : endpoint [sampleendpoint]

  3. my backend service recovers , available

  4. new messages arrives , published via amqpproducersample endpoint does not receive message more. works fine if number of undelivered messages below 5. in case messages delivered backend service. delivery stops working after 5 (five) undelivered messages.

how solve this? there option need set or change make work time?

i using wso2 esb 4.8.1

below full config:

<?xml version="1.0" encoding="utf-8"?> <definitions xmlns="http://ws.apache.org/ns/synapse">     <registry provider="org.wso2.carbon.mediation.registry.wso2registry">         <parameter name="cachableduration">15000</parameter>     </registry>     <proxy name="amqpproxy"            transports="rabbitmq"            startonload="true"            trace="enable">         <description/>         <target>             <insequence>                 <log level="full"/>                 <property name="out_only" value="true"/>                 <property name="force_sc_accepted" value="true" scope="axis2"/>                 <send>                     <endpoint key="sampleendpoint"/>                 </send>             </insequence>         </target>         <parameter name="rabbitmq.queue.name">queue</parameter>         <parameter name="rabbitmq.connection.factory">amqpconnectionfactory</parameter>         <parameter name="rabbitmq.exchange.name">exchange</parameter>         <parameter name="rabbitmq.queue.routing.key">route</parameter>     </proxy>     <proxy name="amqpproducersample"            transports="http"            startonload="true"            trace="disable">         <description/>         <target>             <insequence>                 <property name="out_only" value="true"/>                 <property name="force_sc_accepted" value="true" scope="axis2"/>                 <property name="no_keepalive" value="true" scope="axis2"/>                 <send>                     <endpoint>                         <address uri="rabbitmq:/amqpproxy?rabbitmq.server.host.name=localhost&amp;rabbitmq.server.port=5672&amp;rabbitmq.queue.name=queue&amp;rabbitmq.queue.routing.key=route&amp;rabbitmq.exchange.name=exchange"/>                     </endpoint>                 </send>             </insequence>             <outsequence>                 <send/>             </outsequence>         </target>     </proxy>     <endpoint name="sampleendpoint">         <address uri="http://mfb.localhost/">             <timeout>                 <duration>1000</duration>                 <responseaction>discard</responseaction>             </timeout>             <suspendonfailure>                 <errorcodes>-1</errorcodes>                 <progressionfactor>1.0</progressionfactor>             </suspendonfailure>             <markforsuspension>                 <errorcodes>-1</errorcodes>             </markforsuspension>         </address>     </endpoint>     <sequence name="fault">         <log level="full">             <property name="message" value="executing default 'fault' sequence"/>             <property name="error_code" expression="get-property('error_code')"/>             <property name="error_message" expression="get-property('error_message')"/>         </log>         <drop/>     </sequence>     <sequence name="main">         <in>             <log level="full"/>             <filter source="get-property('to')" regex="http://localhost:9000.*">                 <send/>             </filter>         </in>         <out>             <send/>         </out>         <description>the main sequence message mediation</description>     </sequence> </definitions>

this known bug there in esb 4.8.1 fresh pack. later on have fixed it. recommend switch esb 4.9.0 release issue fixed.

[1] https://docs.wso2.com/display/esb490/downloading+the+product


Comments

Post a Comment

Popular posts from this blog

How to show in django cms breadcrumbs full path? -

-
need advice - how show in breadcrumbs whole path article or page? i've got code: {% ance in ancestors %} <li> {% if not forloop.last %} <a href="{{ ance.get_absolute_url }}">{{ ance.get_menu_title }}</a> {% else %} <span class="active">{{ ance.get_menu_title }}</span> {% endif %} </li> {% endfor %} but shows "home" , current page. how modify show whole path in breadcrumbs? i've found in file menu_tags.py code calls ancestors. @ least there class showbreadcrumbs: class showbreadcrumb(inclusiontag): """ shows breadcrumb node has same url current request - start level: after level should breadcrumb start? 0=home - template: template used render breadcrumb """ name = 'show_breadcrumb' template = 'menu/dummy.html' options = options( argument('start_level', default=0, require...
Read more

php - Invalid Cofiguration - yii\base\InvalidConfigException - Yii2 -

-
Image
i've installed yii2-user module/dektrium yii2-app-basic application command composer require "dektrium/yii2-user:0.9.*@dev" config/console.php return [ . . 'modules' => [ 'gii' => 'yii\gii\module', 'user' => [ 'class' => 'dektrium\user\module', ], ], . . ] config/web.php 'components' => [ . . /* 'user' => [ 'identityclass' => 'app\models\user', 'enableautologin' => true, ], */ 'modules' => [ 'user' => [ 'class' => 'dektrium\user\module', ], ], . . ] after that, run command $ php yii migrate/up --migrationpath=@vendor/dektrium/yii2-user/migrations updating database schema . but, when run http://localhost/mylawsuit/yii/web/index.php?r=u...
Read more

ruby on rails - npm error: tunneling socket could not be established, cause=connect ETIMEDOUT -

-
i have app uses rails framework , implements angularjs part of front end. i have pushed heroku , have heroku toolbelt installed, when try migrate db using "heroku run rake db:migrate" receive following error(s): installing core plugins heroku-cli-addons, heroku-apps, heroku-fork, heroku-git, heroku-local, heroku-run, heroku-status... error installing package. try running again gode_debug=info see more output. ! `run` not heroku command. ! perhaps meant `-h`, `2fa`, `auth`, `join`, `open`, `orgs`, `pg`, `ps` or `rake`. ! see `heroku help` list of available commands. i run command "gode_debug=info heroku run rake db:migrate" , receive error: npm err! darwin 14.5.0 npm err! argv "/users/christopher_pelnar/.heroku/node-v4.2.1-darwin-x64/bin/node" "/users/christopher_pelnar/.heroku/node-v4.2.1-darwin-x64/lib/node_modules/npm/cli.js" "install" "heroku-cli-addons" "heroku-apps" "heroku-fork...
Read more