History | View | Annotate | Download (3.8 kB)
Don't retry forever to reconnect
A bit more well defined error messages
Force the connection obj to re-initialize on error
When an error occurs to the AMQP connection, the code will automaticallyattempt to re-establish the connection. Before this fix, it used thesame (stale) connection object. The fix deletes the object explicitely....
Use log.exception to report exceptions
License header and a bit of documentation
Better error handling in AMQP connector
Format and send email
Persistent connector to AMQP
Maintains an open connection per running interpreter, through a global static variable
"Persistent" connection to AMQP
Uses a global variable, statically initialized, to AMQP.Inspired after a discussion with verigk about persistent objects in Django.