Skip to content

Commit

Permalink
Fix outdated javascript examples
Browse files Browse the repository at this point in the history
  • Loading branch information
weyoss committed Jun 2, 2022
1 parent 642739f commit e31f89c
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 6 deletions.
5 changes: 3 additions & 2 deletions examples/javascript/using-async-await/setup.js
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
const config = require('./config');
const { setLogger, QueueManager } = require('../../..'); // require('redis-smq')
const { QueueManager } = require('../../..'); // require('redis-smq')
const { promisifyAll } = require('bluebird');
const { logger } = require('redis-smq-common');

// Setting up a custom logger
// This step should be also done from your application bootstrap
setLogger(console);
logger.setLogger(console);

const QueueManagerAsync = promisifyAll(QueueManager);

Expand Down
2 changes: 1 addition & 1 deletion examples/javascript/using-callbacks/consumer.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const { Consumer } = require('../../..'); // require('redis-smq')
const config = require('config');
const config = require('./config');

const consumer = new Consumer(config);

Expand Down
2 changes: 1 addition & 1 deletion examples/javascript/using-callbacks/producer.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
const { Producer, Message } = require('../../..'); // require('redis-smq')
const config = require('config');
const config = require('./config');

const producer = new Producer(config);

Expand Down
5 changes: 3 additions & 2 deletions examples/javascript/using-callbacks/setup.js
Original file line number Diff line number Diff line change
@@ -1,9 +1,10 @@
const config = require('./config');
const { setLogger, QueueManager } = require('../../..'); // require('redis-smq')
const { QueueManager } = require('../../..'); // require('redis-smq')
const { logger } = require('redis-smq-common');

// Setting up a custom logger
// This step should be also done from your application bootstrap
setLogger(console);
logger.setLogger(console);

exports.init = function init(cb) {
// Before producing and consuming messages to/from a given queue, we need to make sure that such queue exists
Expand Down

0 comments on commit e31f89c

Please sign in to comment.