diff --git a/client/noop.go b/client/noop.go index b5194a9f..c68a69f5 100644 --- a/client/noop.go +++ b/client/noop.go @@ -221,5 +221,8 @@ func (n *noopClient) Publish(ctx context.Context, p Message, opts ...PublishOpti return n.opts.Broker.Publish(ctx, topic, &broker.Message{ Header: md, Body: body, - }, broker.PublishContext(options.Context)) + }, + broker.PublishContext(options.Context), + broker.PublishBodyOnly(options.BodyOnly), + ) }