FilesExpand file tree

 develop

/

delayed.js

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

executable file

·

42 lines (30 loc) · 847 Bytes

 develop

/

delayed.js

Top

File metadata and controls

• Code
• Blame

executable file

·

42 lines (30 loc) · 847 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

var kue = require('../');

// create our job queue

var jobs = kue.createQueue();

// one minute

var minute = 60000;

var email = jobs.create('email', {

title: 'Account renewal required', to: 'tj@learnboost.com', template: 'renewal-email'

}).delay(minute)

.priority('high')

.save();

email.on('promotion', function () {

console.log('renewal job promoted');

});

email.on('complete', function () {

console.log('renewal job completed');

});

jobs.create('email', {

title: 'Account expired', to: 'tj@learnboost.com', template: 'expired-email'

}).delay(minute * 10)

.priority('high')

.save();

jobs.promote();

jobs.process('email', 10, function (job, done) {

setTimeout(function () {

done();

}, Math.random() * 5000);

});

// start the UI

kue.app.listen(3000);

console.log('UI started on port 3000');