Obfuscate consumer urls
Several internal changes and bug fixes
- Dropped
pubsubin favour of pulsarchannels - Redis backend uses namespace for both channels and queues
- Better serialisation support for messages
- Added
register_brokerfunction to api - Added
queue_messagefunction to api
Backward incompatible release with a considerable amount of internal and API refactoring
- Ability to add additional consumers to the queue server (see pulsar-twitter for example)
- Each consumer is an attribute of the server queue api and backend objects
- Renamed
TaskFuturetoMessageFuture - Handle
max_retrieswithretry_delay TaskErrorcan be used in order to avoid a full stack trace dump. It means it is a TaskError handled by the Job callable.- Added
timeoutto task execution - Max concurrent tasks is a linear function of number of cores and
concurrent_tasksparameter