rabbitmq/rabbitmq-stream-go-client v1.4.6

on GitHub

Milestone

Enhancements

• Bump github.com/spf13/cobra from 1.8.0 to 1.8.1 by @dependabot in #316
• Improve the message log by @Gsantomaggio in #319
• Force localhost when lookup the metadata by @Gsantomaggio in #317
• Add manual commit for super stream consumer by @Gsantomaggio in #323

Deprecation

• Deprecate LastConsumed method by @Gsantomaggio in #324
  The method does not indicate the last message consumed of the stream but the last stored offset.
  The method was added to help the user but created confusion. env.QueryOffset(consumerName, streamName) should be used,
  like:

offset, err := env.QueryOffset(consumerName, streamName) 

/// you may need to do offset+1 to restart from the next message
consumer, err := env.NewConsumer(streamName, handleMessages, stream.
	NewConsumerOptions().
	SetManualCommit().
	SetOffset(stream.OffsetSpecification{}.Offset(offset)).SetConsumerName(consName),
)

Full Changelog: v1.4.5...v1.4.6