我使用的是firebase-queue,我想使用specs的功能。我做了以下工作:
-server端:
var queueRef = firebase.database().ref('queue');
queueRef.child('specs').set({
register: {
start_state : 'register_user',
in_progress_state: 'register_user_in_progress',
timeout: 1000
}
});
var optionRegister = {
specId : 'register',
numWorkers: 1
};
//my worker
var registerQueue = new Queue(queueRef,optionRegister,function(data, progress, resolve, reject) {
// Read and process task data
console.log(data);
});-client端:
var ref = firebase.database().ref('queue/tasks');
ref.push({ '_start': 'register_user', 'id': user1 });在firebase数据库中,我看到了正确添加的任务和规范:my database view
-Versions Node.js v7.0.0 firebase v3.5.3 firebase-queue v1.5.0
问题是,这个任务从来没有被工人接受过,我找不到原因。有人能帮我吗?谢谢。
发布于 2016-12-01 17:50:52
除了“_start”对象之外,一切似乎都是正确的。它实际上是'_state‘对象。尝试更改此设置。希望这能有所帮助。
ref.push({ '_state': 'register_user', 'id': user1 });https://stackoverflow.com/questions/40449370
复制相似问题