lp:~txamqpteam/txamqp/support-basic-return
- Get this branch:
- bzr branch lp:~txamqpteam/txamqp/support-basic-return
Branch merges
- Dan Di Spaltro: Approve (code)
- Esteve Fernandez: Approve
- Diff: None lines
Branch information
Recent revisions
- 22. By Terry Jones
-
Cleaned up handling of KeyError n txamqp/
contrib/ thrift/ client. py (which had a silly logic error - of mine). Added a __repr__ to the Content class in txamqp/content.py. And I now have a reproducible example of 'headers' not being in msg.content when trying to get the thriftClientName in txamqp/ contrib/ thrift/ client. py though haven't tried to dig into why it happens. - 20. By Terry Jones
-
Added some logging to report on a situation I ran across wherein a msg did not have a thriftClient header. I don't know what caused this to occur and didn't try hard to reproduce it (I only saw it in a log file about 10 minutes after it had happened). So the code in this change is not even tested.
- 19. By Terry Jones
-
Added support for sending a 'mandatory' flag to basic_publish to make AMQP respond with a basic_return if a message is unroutable. The basic_return reply is delivered to a client-specific queue so we know to whom the message was intended. A thrift.
transport. TTransport. TTransportExcep tion is raised when a message is unroutable. You must use a txamqp. contrib. thrift. client. ThriftTwistedDe legate to use this code, as it knows how to look for a custom thriftClientName field in the returned message header in order to get the message into the correct local queue. Also note that the changes in this branch do not know how to deal with Thrift oneway (formerly async) methods as there is no deferred waiting on the result whose errback we can call. - 18. By Terry Jones
-
Added support for calling errback with a thrift.
transport. TTransport. TTransportExcep tion when AMQP responds with a basic return due to an unroutable request.
Branch metadata
- Branch format:
- Branch format 7
- Repository format:
- Bazaar RepositoryFormatKnitPack6 (bzr 1.9)
- Stacked on:
- lp:txamqp