docs: update examples

weyoss · Mar 24, 2024 · d80beb2 · d80beb2
1 parent 96a2666
commit d80beb2
Show file tree

Hide file tree

Showing 5 changed files with 21 additions and 19 deletions.
diff --git a/examples/javascript/using-async-await.cjs b/examples/javascript/using-async-await.cjs
@@ -15,9 +15,9 @@ const {
   ProducibleMessage,
   Queue,
   EQueueType,
-  EQueueDeliveryMode,
+  EQueueDeliveryModel,
   Configuration,
-} = require('../..');
+} = require('redis-smq');
 
 const config = {
   namespace: 'ns1',
@@ -59,7 +59,7 @@ const createQueue = async () => {
     await queue.saveAsync(
       'test_queue',
       EQueueType.LIFO_QUEUE,
-      EQueueDeliveryMode.POINT_TO_POINT,
+      EQueueDeliveryModel.POINT_TO_POINT,
     );
     await queue.shutdownAsync();
   }

diff --git a/examples/javascript/using-async-await.js b/examples/javascript/using-async-await.js
@@ -12,12 +12,12 @@ import bluebird from 'bluebird';
 import {
   Configuration,
   Consumer,
-  EQueueDeliveryMode,
+  EQueueDeliveryModel,
   EQueueType,
   Producer,
   ProducibleMessage,
   Queue,
-} from '../..'; // redis-smq
+} from 'redis-smq';
 
 const { promisifyAll } = bluebird;
 
@@ -61,7 +61,7 @@ const createQueue = async () => {
     await queue.saveAsync(
       'test_queue',
       EQueueType.LIFO_QUEUE,
-      EQueueDeliveryMode.POINT_TO_POINT,
+      EQueueDeliveryModel.POINT_TO_POINT,
     );
     await queue.shutdownAsync();
   }

diff --git a/examples/javascript/using-callbacks.cjs b/examples/javascript/using-callbacks.cjs
@@ -7,16 +7,16 @@
  * in the root directory of this source tree.
  */
 
-const { logger, ERedisConfigClient } = require('redis-smq-common');
+const { ERedisConfigClient, logger } = require('redis-smq-common');
 const {
+  Configuration,
   Consumer,
   Producer,
-  ProducibleMessage,
   Queue,
-  Configuration,
   EQueueType,
-  EQueueDeliveryMode,
-} = require('../..'); // redis-smq
+  EQueueDeliveryModel,
+  ProducibleMessage,
+} = require('redis-smq');
 
 const config = {
   namespace: 'ns1',
@@ -57,7 +57,7 @@ const createQueue = (cb) => {
       queue.save(
         'test_queue',
         EQueueType.LIFO_QUEUE,
-        EQueueDeliveryMode.POINT_TO_POINT,
+        EQueueDeliveryModel.POINT_TO_POINT,
         (err) => {
           if (err) cb(err);
           else queue.shutdown(cb);

diff --git a/examples/javascript/using-callbacks.js b/examples/javascript/using-callbacks.js
@@ -11,12 +11,12 @@ import { ERedisConfigClient, logger } from 'redis-smq-common';
 import {
   Configuration,
   Consumer,
-  EQueueDeliveryMode,
-  EQueueType,
-  Message,
   Producer,
   Queue,
-} from '../..'; // redis-smq
+  EQueueType,
+  EQueueDeliveryModel,
+  ProducibleMessage,
+} from 'redis-smq';
 
 const config = {
   namespace: 'ns1',
@@ -57,7 +57,7 @@ const createQueue = (cb) => {
       queue.save(
         'test_queue',
         EQueueType.LIFO_QUEUE,
-        EQueueDeliveryMode.POINT_TO_POINT,
+        EQueueDeliveryModel.POINT_TO_POINT,
         (err) => {
           if (err) cb(err);
           else queue.shutdown(cb);
@@ -72,7 +72,7 @@ const produce = (cb) => {
   producer.run((err) => {
     if (err) cb(err);
     else {
-      const msg = new Message();
+      const msg = new ProducibleMessage();
       msg
         .setBody({ ts: `Current time is ${Date.now()}` })
         .setQueue('test_queue');

diff --git a/examples/typescript/using-async-await.ts b/examples/typescript/using-async-await.ts
@@ -7,7 +7,7 @@
  * in the root directory of this source tree.
  */
 
-import { promisifyAll } from 'bluebird';
+import bluebird from 'bluebird';
 import { ERedisConfigClient, logger } from 'redis-smq-common';
 import {
   Configuration,
@@ -20,6 +20,8 @@ import {
   Queue,
 } from '../../index.js'; // redis-smq
 
+const { promisifyAll } = bluebird;
+
 export const config: IRedisSMQConfig = {
   namespace: 'ns1',
   redis: {