Merge branch 'master' of ssh://github.com/micro/go-micro
This commit is contained in:
commit
cf2f8a9a55
@ -280,7 +280,7 @@ func (g *grpcClient) Options() client.Options {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (g *grpcClient) NewMessage(topic string, msg interface{}, opts ...client.MessageOption) client.Message {
|
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 {
|
func (g *grpcClient) NewRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request {
|
||||||
|
Loading…
Reference in New Issue
Block a user