处理未知消息
(message *pb.NodeStreamMessage)
| 482 | |
| 483 | // 处理未知消息 |
| 484 | func (this *APIStream) handleUnknownMessage(message *pb.NodeStreamMessage) error { |
| 485 | this.replyFail(message.RequestId, "unknown message code '"+message.Code+"'") |
| 486 | return nil |
| 487 | } |
| 488 | |
| 489 | // 回复失败 |
| 490 | func (this *APIStream) replyFail(requestId int64, message string) { |