diff options
Diffstat (limited to 'plugins/temporal/protocol/proto_codec.go')
| -rw-r--r-- | plugins/temporal/protocol/proto_codec.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/plugins/temporal/protocol/proto_codec.go b/plugins/temporal/protocol/proto_codec.go index b41f02b6..607fe0fe 100644 --- a/plugins/temporal/protocol/proto_codec.go +++ b/plugins/temporal/protocol/proto_codec.go @@ -120,6 +120,7 @@ func (c *ProtoCodec) packMessage(msg Message) (*internal.Message, error) { } func (c *ProtoCodec) parseMessage(frame *internal.Message) (Message, error) { + const op = errors.Op("proto_codec_parse_message") var err error msg := Message{ @@ -131,12 +132,12 @@ func (c *ProtoCodec) parseMessage(frame *internal.Message) (Message, error) { if frame.Command != "" { msg.Command, err = initCommand(frame.Command) if err != nil { - return Message{}, err + return Message{}, errors.E(op, err) } err = jsoniter.Unmarshal(frame.Options, &msg.Command) if err != nil { - return Message{}, err + return Message{}, errors.E(op, err) } } |