python - RabbitMQ Message/Topic Receiver Crashing when RabbitMQ is not running -

-

i using python , pika on linux os environment. message/topic receiver keeps crashing when rabbitmq not running. wondering there way keep message/topic receiver running when rabbitmq not because rabbitmq not on same virtual machine message/topic receiver.

this cover if rabbitmq crashes reason message/topic receiver should keep running. saving having start/restart message/topic receiver again.

as far understand "message/topic reciever" in case consumer. responsible make application in such way catch exception if trying connect not running rabbitmq.

for example:

creds = pika.plaincredentials(**creds)                              params = pika.connectionparameters(credentials=creds,                                                       **conn_params)                   try:                                                                         connection = pika.blockingconnection(params)                        log.info("connection rabbit established")                         return connection                                               except (probableauthenticationerror, authenticationerror):                   log.error("authentication failed", exc_info=true)                    except probableaccessdeniederror:                                            log.error("the virtual host configured wrong!", exc_info=true)          except channelclosed:                                                        log.error("channelclosed error", exc_info=true)                      except amqpconnectionerror:                                                  log.error("rabbitmq server down or host unreachable")                 log.error("connection attempt timed out!")                               log.error("trying re-connect rabbitmq...")                         time.sleep(reconnection_interval)       # <here goes reconnection logic >

and far making sure rabbit server , running:

  • you can create cluster make queue durable, ha

  • install type of supervision (let monit or supervisord) , configure check rabbit process. example:

    check process rabbitmq pidfile /var/run/rabbitmq/pid                          start program = "/etc/init.d/rabbitmq-server stop"                               stop program = "/etc/init.d/rabbitmq-server start"                               if 3 restarts within 5 cycles alert

Comments

Post a Comment

Popular posts from this blog

c# - How to get the current UAC mode -

-
can check current uac type set in device before running application through c#. i got know approach check whether current user administrator or not. but, need know uac type set (i.e. default/never notify) internal logic. is possible? please help. this article self-elevation , checking level program runs in. due security reasons i'm afraid won't able retrieve uac level set. http://code.msdn.microsoft.com/windowsdesktop/csuacselfelevation-644673d3
Read more

postgresql - Lazarus + Postgres: incomplete startup packet -

-
i've been building lazarus pascal program using postgresql on back-end. used work fine following lines opening db. dbconn:= tpqconnection.create(nil); dbconn.hostname := 'localhost'; dbconn.databasename:= 'dbhrs'; dbconn.username:='mizk'; dbconn.password:='123'; dbconn.open; if dbconn.connected openhrsdb := true else openhrsdb := false; but moment change localhost server's ip (on lan), program stops. no errors or warnings. have no clue happening. here related details may narrow down problem. the program i'm running workstation on same lan server. both machines run ubuntu 12.04 desktop i can access postgres db on server using pgadmin iii, guess it's not firewall issue. i have allowed postgresql ufw , ufw disabled. strangely, when firewall disabled, can ssh server terminal using workstation. when it's enabled, can't my biggest concern right why pascal program not working when i...
Read more

javascript - Ajax jqXHR.status==0 fix error -

-
$.ajax({ url: urlstring, datatype: "json", type: "get", success: function (data) { alert(data); }, error: function (jqxhr, exception) { if (jqxhr.status === 0) { alert('not connect.\n verify network.'); } else if (jqxhr.status == 404) { alert('requested page not found. [404]'); } else if (jqxhr.status == 500) { alert('internal server error [500].'); } else if (exception === 'parsererror') { alert('requested json parse failed.'); } else if (exception === 'timeout') { alert('time out error.'); } else if (exception === 'abort') { alert('ajax request aborted.'); } else { alert('uncaught error.\n' + jqxhr.responsete...
Read more