History¶
1.0.1 (2019-04-24)¶
- Fix long description in packaging
1.0.0 (2019-04-24)¶
- Drop support for python 2.6 and python 3.3, add support for python 3.7
- Drop support for nsq < 1.0.0
- Handle changing connections during redistribute ready
- Add create topic and create channel to LookupdClient
- Add pause and unpause topic to NsqdHTTPClient
- Add ability to filter NsqdHTTPClient stats by topic/channel
- Add text format for NsqdHTTPClient stats
- Add binary multipublish over http
- Add queue handler to the contrib package
- Add Producer class, a high level tcp message writer
- Fixed detecting if consumer is starved
- Optimizations to better distribute ready state among the nsqd connections
- Detect starved consumers when batching messages
- [DEPRECATED]
Nsqd
is deprecated. UseNsqdTCPClient
orNsqdHTTPClient
instead. See Version 1.0.0 for more information. - [DEPRECATED]
Lookupd
is deprecated. UseLookupdClient
instead. See Version 1.0.0 for more information. - [DEPRECATED]
Reader
is deprecated. UseConsumer
instead. See Version 1.0.0 for more information.
0.4.0 (2017-06-13)¶
- #13 - Allow use with nsq v1.0.0 (thanks @daroot)
- Add contrib package with utilities.
0.3.3 (2016-09-25)¶
- #11 - Make sure all socket data is sent.
- #5 - Add support for DPUB (defered publish).
0.3.2 (2016-04-10)¶
- Add support for Python 3 and PyPy.
- #7 - Fix undeclared variable in compression socket.
0.3.1 (2015-11-06)¶
- Fix negative in flight causing not throttling after backoff.
0.3.0 (2015-06-14)¶
- Fix extra backoff success/failures during backoff period.
- Fix case where handle_backoff is never called.
- Add backoff parameter to message.requeue().
- Allow overriding backoff on NSQRequeueMessage error.
- Handle connection failures while starting/completing backoff.
0.2.3 (2015-02-16)¶
- Remove disconnected nsqd messages from the worker queue.
- #4 - Fix crash in Reader.random_ready_conn (thanks @ianpreston).
0.2.2 (2015-01-12)¶
- Allow finishing and requeuing in sync handlers.
0.2.1 (2015-01-12)¶
- Topics and channels are now valid to 64 characters.
- Ephemeral topics are now valid.
- Adjustable backoff behavior.
0.2.0 (2014-08-03)¶
- Warn on connection failure.
- Add extra requires for snappy.
- Add support for nsq auth protocol.
0.1.4 (2014-07-24)¶
- Preemptively update ready count.
- Dependency and contributing documentation.
- Support for nsq back to 0.2.24.
0.1.3 (2014-07-08)¶
- Block as expected on start, even if already started.
- Raise runtime error if starting the reader without a message handler.
- Add on_close signal to the reader.
- Allow upgrading to tls+snappy or tls+deflate.
0.1.2 (2014-07-08)¶
- Flush delfate buffer for each message.
0.1.1 (2014-07-07)¶
- Fix packaging stream submodule.
- Send queued messages before closing socket.
- Continue to read from socket on EAGAIN
0.1.0 (2014-07-07)¶
- First release on PyPI.