- Include jitter to discovery interval lookups
- Typecast to String on PUB and MPUB
- Update exception types used for not implemented methods
- Add #confirm, #requeue, and #touch helpers to FrameType::Message instances
- Update Utils::Lazy implementation to be faster and clearer
- Add #safe_socket method on Connection to add stability
- Rebuild connections on error to prevent consumer teardown
- Reference connections without requirement of connection instance being alive
- Use #read over #recv on underlying socket to ensure proper number of bytes (thanks @thomas-holmes)
- Expand spec testing
A big thanks to @bschwartz for a large contribution in this changeset including expanded spec coverage, message proxy helper methods, and isolation of instability around Connection interactions.
- Fix
nsqlookupd
attribute inConsumer
andDiscovery
- Fix the rest of the namespacing issues
- Start adding some tests
- Use better exception types (NotImplementedError instead of NoMethodError)
- Be smart about responses within connections
- Add snappy support
- Add deflate support
- Add TLS support
- Prevent division by zero in distribution
- Add query methods to lazy helper (
attribute_name
?)
- Include backoff support
- Remove
method_missing
magic - Force message redistribution when connection removed
- Make discovery interval configurable
- Add support for HTTP producer
- Include namespace for custom exceptions #1 (thanks @copiousfreetime)
- Fix timeout method access in req command #1 (thanks @copiousfreetime)
- Add logging support
- Include valid responses within commands
- Segregate responses from messages
- Manage connections in consumer (closed/reconnect)
- Add message distribution support
- Initial release