我使用ActionCable创建了以下内容,但无法接收正在广播的任何数据。
评论频道
class CommentsChannel < ApplicationCable::Channel
def subscribed
comment = Comment.find(params[:id])
stream_for comment
end
endJavaScript
var cable = Cable.createConsumer('ws://localhost:3000/cable');
var subscription = cable.subscriptions.create({
channel: "CommentsChannel",
id: 1
},{
received: function(data) {
console.log("Received data")
}
});它连接得很好,我可以在日志中看到以下内容:
CommentsChannel is streaming from comments:Z2lkOi8vdHJhZGUtc2hvdy9FdmVudC8x然后我向那条溪流广播:
ActionCable.server.broadcast "comments:Z2lkOi8vdHJhZGUtc2hvdy9FdmVudC8x", { test: '123' }问题是从来没有调用过received函数。我做错了什么吗?
注意:我正在使用actioncable npm包从BackboneJS应用程序连接。
发布于 2016-04-01 22:36:17
将电缆适配器从async改为redis in config/cable.yml为我修复了它。
更新
正如下面Erem所指出的,服务器和控制台是独立的进程,因此需要使用集中式队列管理器。
https://stackoverflow.com/questions/36266746
复制相似问题