diff --git a/client/options.go b/client/options.go index 6f854d17..2d201510 100644 --- a/client/options.go +++ b/client/options.go @@ -291,6 +291,12 @@ func WithDialTimeout(d time.Duration) CallOption { } } +func WithMessageContentType(ct string) MessageOption { + return func(o *MessageOptions) { + o.ContentType = ct + } +} + // Request Options func WithContentType(ct string) RequestOption {