Versions in this module Expand all Collapse all v2 v2.6.0 Apr 26, 2021 Changes in this version + func BufferMessage(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (binding.Message, error) + func CopyMessage(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (binding.Message, error) + func WithAcksBeforeFinish(m binding.Message, requiredAcks int) binding.Message
Go to main page