From 869c6ec76466ee5134fb907d56b2eaa7b2e7e92d Mon Sep 17 00:00:00 2001
From: johnson <chengqiaosheng@gmail.com>
Date: Tue, 18 Jun 2019 17:07:31 +0800
Subject: [PATCH] grpc message should be able to set

---
 grpc.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/grpc.go b/grpc.go
index ebdbed5..7a8aacf 100644
--- a/grpc.go
+++ b/grpc.go
@@ -291,7 +291,7 @@ func (g *grpcClient) Options() client.Options {
 }
 
 func (g *grpcClient) NewMessage(topic string, msg interface{}, opts ...client.MessageOption) client.Message {
-	return newGRPCPublication(topic, msg, "application/octet-stream")
+	return newGRPCPublication(topic, msg, g.opts.ContentType, opts...)
 }
 
 func (g *grpcClient) NewRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request {