Method OnMessage

sync/msg_handler.go:13–15

(msg interface{})

}

func (h *handler) OnMessage(msg interface{}) error {
	return h.link.Send(msg.(*v1.Message))
}

func (h *handler) OnTimeout() error {
	msg := &v1.Message{