Skip to content

0.3.2

Compare
Choose a tag to compare
@jhalterman jhalterman released this 06 Feb 04:14
· 150 commits to master since this release

API changes:

  • RecoveryPolicy was broken out into a separate class.
  • RetryPolicy was moved to the net.jodah.lyra.config package.
  • ConnectionListener.onChannelRecovery was added.
  • ChannelListener.onConsumerRecovery was added.

Behavioral changes:

  • When a channel is closed and recovered, attempts to ack/nack/reject messages that were delivered before the channel was recovered are simply ignored since their delivery tags will be invalid for the newly recovered channel. Instead these messages will be re-delivered with new delivery tags.
  • ConnectionListener.onRecovery is now called after the connection is recovered, but before the channels are recovered. ConnectionListener.onChannelRecovery is called after the connection and channels are recovered.
  • ChannelListener.onRecovery is now called after the channel is recovered, but before the consumers are recovered. ChannelListener.onConsumerRecovery is called after the channel and consumers are recovered.

Bug Fixes

  • Fixed issue #18 Unable to invoke withConsumerListeners() on ConfigurableChannel.
  • Fixed issue #13 Fix ConnectionOptions.withAddresses using Address list.