Merge branch 'v3' into cleanup

2022-03-21 15:31:43 +03:00
parent dc01d20561 cdee03a96e
commit d1c11644e8
2 changed files with 28 additions and 8 deletions
--- a/subscriber.go
+++ b/subscriber.go
@@ -122,8 +122,8 @@ func (g *grpcServer) createSubHandler(sb *subscriber, opts server.Options) broke

 		ct := msg.Header["Content-Type"]
 		if len(ct) == 0 {
-			msg.Header["Content-Type"] = defaultContentType
-			ct = defaultContentType
+			msg.Header["Content-Type"] = DefaultContentType
+			ct = DefaultContentType
 		}
 		cf, err := g.newCodec(ct)
 		if err != nil {