Skip to content

murayama/node-queue

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

3 Commits
 
 
 
 
 
 

Repository files navigation

node.jsでredisを使用したqueue処理

create client

var q = MyQueue.createQueue('queue_name', 6379, '127.0.0.1');

or

var rings = {'localhost:6379':1, 'localhost:6380':1, 'localhost:6381':1};
var q = MyQueue.shard(key, rings).createQueue('queue_name');

enqueue

q.enqueue({data:'test'});
q.push({data:'test'});

dequeue

q.dequeue(function (err, data) {
  //   
});

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

 
 
 

Contributors