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. Use NsqdTCPClient or NsqdHTTPClient instead. See Version 1.0.0 for more information.
  • [DEPRECATED] Lookupd is deprecated. Use LookupdClient instead. See Version 1.0.0 for more information.
  • [DEPRECATED] Reader is deprecated. Use Consumer 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.