如何观察在 Sails .js 中添加到模型中的新记录

当用户向用户聊天消息传递系统中的某个特定 Id（在用户模型中）发送消息时，我正在尝试推送消息。我无法让它工作，也不知道如何开始。我的Messaging控制器中有这个：

sendAndReceiveMsgs: function(req, res) {
    if (req.isSocket && req.param('message') && req.param('to')) {
        var message = req.param('message'),
            from = req.user.id,
            to = req.param('to');
        Messaging.create({ message: message, from: from, to: to })
            .exec(function (err, created) {
                console.log('sent');
        });
    } else if (req.isSocket) {
        Messaging.find({ where: { to: req.user.id }, limit: 1, sort: 'id DESC' })
        .exec(function(err, messages) {
            if(messages.length > 0){
                console.log(message.length + " new messages");
            } else {
                console.log("No new messages");
            }
            Messaging.subscribe(req.socket, message);
            Messaging.watch(req);
            Messaging.publishCreate({ id: message[0].id, message: message[0].message });
        });
    } else if (!req.isSocket) {
        return res.notFound();
    }
}

但是，它不会向用户推送进一步的新消息（为他准备）。有什么线索吗？我真的不明白这一点，也不知道从这里去哪里。谢谢！