From 8a50a2d0b803fabcf88424b907eb5289245458db Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Wed, 25 Nov 2020 08:33:29 +0300
Subject: [PATCH] receives only body of the message

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 broker/options.go | 21 ++++++++++++++++++++-
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/broker/options.go b/broker/options.go
index fae5aaaf..2295c23f 100644
--- a/broker/options.go
+++ b/broker/options.go
@@ -50,6 +50,8 @@ func Context(ctx context.Context) Option {
 
 // PublishOptions struct
 type PublishOptions struct {
+	// BodyOnly says that only body of the message must be published
+	BodyOnly bool
 	// Other options for implementations of the interface
 	// can be stored in a context
 	Context context.Context
@@ -81,6 +83,9 @@ type SubscribeOptions struct {
 	// receives a subset of messages.
 	Group string
 
+	// BodyOnly says that consumed only body of the message
+	BodyOnly bool
+
 	// Other options for implementations of the interface
 	// can be stored in a context
 	Context context.Context
@@ -92,6 +97,13 @@ type Option func(*Options)
 // PublishOption func
 type PublishOption func(*PublishOptions)
 
+// PublishBodyOnly publish only body of the message
+func PublishBodyOnly(b bool) PublishOption {
+	return func(o *PublishOptions) {
+		o.BodyOnly = b
+	}
+}
+
 // PublishContext sets the context
 func PublishContext(ctx context.Context) PublishOption {
 	return func(o *PublishOptions) {
@@ -146,6 +158,13 @@ func SubscribeAutoAck(b bool) SubscribeOption {
 	}
 }
 
+// SubscribeBodyOnly consumes only body of the message
+func SubscribeBodyOnly(b bool) SubscribeOption {
+	return func(o *SubscribeOptions) {
+		o.BodyOnly = b
+	}
+}
+
 // ErrorHandler will catch all broker errors that cant be handled
 // in normal way, for example Codec errors
 func ErrorHandler(h Handler) Option {
@@ -162,7 +181,7 @@ func SubscribeErrorHandler(h Handler) SubscribeOption {
 	}
 }
 
-// Queue sets the subscribers sueue
+// Deprecated: Queue sets the subscribers sueue
 func Queue(name string) SubscribeOption {
 	return func(o *SubscribeOptions) {
 		o.Group = name