collexx-rabbitmq - npm Package Compare versions

Comparing version 0.0.7 to 0.0.8

dist/setting/channel.js

@@ -17,7 +17,19 @@ "use strict";
     },
-    physical_nft_transfer_queue_channel: {
-        name: 'physical_nft_transfer_queue_channel',
+    seed_tranfser_channel: {
+        name: 'seed_tranfser_channel',
         type: 'consumer',
     },
+    nft_tranfser_channel: {
+        name: 'nft_tranfser_channel',
+        type: 'consumer',
+    },
+    nft_deposit_channel: {
+        name: 'nft_deposit_channel',
+        type: 'consumer',
+    },
+    physical_nft_deposit_channel: {
+        name: 'physical_nft_deposit_channel',
+        type: 'consumer',
+    },
 };
 //# sourceMappingURL=channel.js.map

dist/setting/consumer.js

@@ -13,11 +13,15 @@ "use strict";
         QUEUE: queue_1.queues.SEED_TRANSFER,
-        CHANNEL_NAME: channel_1.channels.confirmed.name,
+        CHANNEL_NAME: channel_1.channels.seed_tranfser_channel.name,
     },
     NFT_TRANSFER: {
         QUEUE: queue_1.queues.NFT_TRANSFER,
-        CHANNEL_NAME: channel_1.channels.confirmed.name,
+        CHANNEL_NAME: channel_1.channels.nft_tranfser_channel.name,
     },
+    NFT_DEPOSIT: {
+        QUEUE: queue_1.queues.NFT_TRANSFER,
+        CHANNEL_NAME: channel_1.channels.nft_deposit_channel.name,
+    },
     PHYSICAL_NFT_TRANSFER: {
         QUEUE: queue_1.queues.PHYSICAL_NFT_TRANSFER,
-        CHANNEL_NAME: channel_1.channels.confirmed.name,
+        CHANNEL_NAME: channel_1.channels.physical_nft_deposit_channel.name,
     },
@@ -24,0 +28,0 @@ UNHANDLED_EXCEPTION_QUEUE: {

dist/setting/exchange.js

@@ -7,3 +7,3 @@ "use strict";
 exports.exchanges = {
-    RAFFLE_TRANSFER: {
+    DIRECT_EXCHANGE: {
         name: `raffle.transfer`,
@@ -15,4 +15,4 @@ type: 'direct',
     },
-    PHYSICAL_NFT_TRANSFER: {
-        name: `physicalnft.transfer`,
+    SINGLE_ACTIVE: {
+        name: `single.active`,
         type: 'direct',
@@ -19,0 +19,0 @@ headers: {

dist/setting/publisher.js

@@ -13,15 +13,15 @@ "use strict";
         QUEUE: queue_1.queues.SEED_TRANSFER,
-        CHANNEL_NAME: channel_1.channels.confirmed.name,
+        CHANNEL_NAME: channel_1.channels.seed_tranfser_channel.name,
     },
     NFT_TRANSFER: {
         QUEUE: queue_1.queues.NFT_TRANSFER,
-        CHANNEL_NAME: channel_1.channels.confirmed.name,
+        CHANNEL_NAME: channel_1.channels.nft_tranfser_channel.name,
     },
     NFT_DEPOSIT: {
         QUEUE: queue_1.queues.NFT_DEPOSIT,
-        CHANNEL_NAME: channel_1.channels.confirmed.name,
+        CHANNEL_NAME: channel_1.channels.nft_deposit_channel.name,
     },
     PHYSICAL_NFT_TRANSFER: {
         QUEUE: queue_1.queues.PHYSICAL_NFT_TRANSFER,
-        CHANNEL_NAME: channel_1.channels.physical_nft_transfer_queue_channel.name,
+        CHANNEL_NAME: channel_1.channels.physical_nft_deposit_channel.name,
     },
@@ -28,0 +28,0 @@ UNHANDLED_EXCEPTION_QUEUE: {

dist/setting/queue.js

@@ -10,3 +10,3 @@ "use strict";
         QUEUE_NAME: `raffle_queue`,
-        EXCHANGE: exchange_1.exchanges.RAFFLE_TRANSFER,
+        EXCHANGE: exchange_1.exchanges.DIRECT_EXCHANGE,
         HEADERS: {
@@ -20,16 +20,34 @@ durable: true,
         QUEUE_NAME: `seed_tranfser`,
+        EXCHANGE: exchange_1.exchanges.DIRECT_EXCHANGE,
+        HEADERS: {
+            durable: true,
+            deadLetterExchange: 'dlx',
+            deadLetterRoutingKey: 'seed_tranfser_dlq',
+        },
     },
     NFT_TRANSFER: {
         QUEUE_NAME: `nft_tranfser`,
+        EXCHANGE: exchange_1.exchanges.DIRECT_EXCHANGE,
+        HEADERS: {
+            durable: true,
+            deadLetterExchange: 'dlx',
+            deadLetterRoutingKey: 'nft_tranfser_dlq',
+        },
     },
     NFT_DEPOSIT: {
         QUEUE_NAME: `nft_deposit`,
+        EXCHANGE: exchange_1.exchanges.DIRECT_EXCHANGE,
+        HEADERS: {
+            durable: true,
+            deadLetterExchange: 'dlx',
+            deadLetterRoutingKey: 'nft_deposit_dlq',
+        },
     },
     PHYSICAL_NFT_TRANSFER: {
         QUEUE_NAME: `physical_nft_deposit`,
-        EXCHANGE: exchange_1.exchanges.PHYSICAL_NFT_TRANSFER,
+        EXCHANGE: exchange_1.exchanges.DIRECT_EXCHANGE,
         HEADERS: {
             durable: true,
             deadLetterExchange: 'dlx',
-            deadLetterRoutingKey: 'physical_nft_deposit_dlq',
+            deadLetterRoutingKey: 'physical_nft_transfer_dlq',
         },
@@ -36,0 +54,0 @@ },

package.json

 {
   "name": "collexx-rabbitmq",
-  "version": "0.0.7",
+  "version": "0.0.8",
   "description": "Collexx RabbitMQ Package",
@@ -5,0 +5,0 @@ "author": "collexx",

src/setting/channel.ts

@@ -16,6 +16,18 @@ import { IChannel } from 'src/interfaces';
   },
-  physical_nft_transfer_queue_channel: {
-    name: 'physical_nft_transfer_queue_channel',
+  seed_tranfser_channel: {
+    name: 'seed_tranfser_channel',
     type: 'consumer',
   },
+  nft_tranfser_channel: {
+    name: 'nft_tranfser_channel',
+    type: 'consumer',
+  },
+  nft_deposit_channel: {
+    name: 'nft_deposit_channel',
+    type: 'consumer',
+  },
+  physical_nft_deposit_channel: {
+    name: 'physical_nft_deposit_channel',
+    type: 'consumer',
+  },
 };

src/setting/consumer.ts

@@ -10,14 +10,17 @@ import { IPublish } from 'src/interfaces';
   },
-
   SEED_TRANSFER: {
     QUEUE: queues.SEED_TRANSFER,
-    CHANNEL_NAME: channels.confirmed.name,
+    CHANNEL_NAME: channels.seed_tranfser_channel.name,
   },
   NFT_TRANSFER: {
     QUEUE: queues.NFT_TRANSFER,
-    CHANNEL_NAME: channels.confirmed.name,
+    CHANNEL_NAME: channels.nft_tranfser_channel.name,
   },
+  NFT_DEPOSIT: {
+    QUEUE: queues.NFT_TRANSFER,
+    CHANNEL_NAME: channels.nft_deposit_channel.name,
+  },
   PHYSICAL_NFT_TRANSFER: {
     QUEUE: queues.PHYSICAL_NFT_TRANSFER,
-    CHANNEL_NAME: channels.confirmed.name,
+    CHANNEL_NAME: channels.physical_nft_deposit_channel.name,
   },
@@ -24,0 +27,0 @@ UNHANDLED_EXCEPTION_QUEUE: {

src/setting/exchange.ts

@@ -7,3 +7,3 @@ import * as dotenv from 'dotenv';
 export const exchanges: { [key: string]: IExchange } = {
-  RAFFLE_TRANSFER: {
+  DIRECT_EXCHANGE: {
     name: `raffle.transfer`,
@@ -15,4 +15,4 @@ type: 'direct',
   },
-  PHYSICAL_NFT_TRANSFER: {
-    name: `physicalnft.transfer`,
+  SINGLE_ACTIVE: {
+    name: `single.active`,
     type: 'direct',
@@ -19,0 +19,0 @@ headers: {

src/setting/publisher.ts

@@ -12,15 +12,15 @@ import { IPublish } from 'src/interfaces';
     QUEUE: queues.SEED_TRANSFER,
-    CHANNEL_NAME: channels.confirmed.name,
+    CHANNEL_NAME: channels.seed_tranfser_channel.name,
   },
   NFT_TRANSFER: {
     QUEUE: queues.NFT_TRANSFER,
-    CHANNEL_NAME: channels.confirmed.name,
+    CHANNEL_NAME: channels.nft_tranfser_channel.name,
   },
   NFT_DEPOSIT: {
     QUEUE: queues.NFT_DEPOSIT,
-    CHANNEL_NAME: channels.confirmed.name,
+    CHANNEL_NAME: channels.nft_deposit_channel.name,
   },
   PHYSICAL_NFT_TRANSFER: {
     QUEUE: queues.PHYSICAL_NFT_TRANSFER,
-    CHANNEL_NAME: channels.physical_nft_transfer_queue_channel.name,
+    CHANNEL_NAME: channels.physical_nft_deposit_channel.name,
   },
@@ -27,0 +27,0 @@ UNHANDLED_EXCEPTION_QUEUE: {

src/setting/queue.ts

@@ -9,3 +9,3 @@ import { IQueue } from 'src/interfaces';
     QUEUE_NAME: `raffle_queue`,
-    EXCHANGE: exchanges.RAFFLE_TRANSFER,
+    EXCHANGE: exchanges.DIRECT_EXCHANGE,
     HEADERS: {
@@ -20,17 +20,34 @@ durable: true,
     QUEUE_NAME: `seed_tranfser`,
+    EXCHANGE: exchanges.DIRECT_EXCHANGE,
+    HEADERS: {
+      durable: true,
+      deadLetterExchange: 'dlx',
+      deadLetterRoutingKey: 'seed_tranfser_dlq',
+    },
   },
   NFT_TRANSFER: {
     QUEUE_NAME: `nft_tranfser`,
+    EXCHANGE: exchanges.DIRECT_EXCHANGE,
+    HEADERS: {
+      durable: true,
+      deadLetterExchange: 'dlx',
+      deadLetterRoutingKey: 'nft_tranfser_dlq',
+    },
   },
   NFT_DEPOSIT: {
     QUEUE_NAME: `nft_deposit`,
+    EXCHANGE: exchanges.DIRECT_EXCHANGE,
+    HEADERS: {
+      durable: true,
+      deadLetterExchange: 'dlx',
+      deadLetterRoutingKey: 'nft_deposit_dlq',
+    },
   },
   PHYSICAL_NFT_TRANSFER: {
     QUEUE_NAME: `physical_nft_deposit`,
-    EXCHANGE: exchanges.PHYSICAL_NFT_TRANSFER,
+    EXCHANGE: exchanges.DIRECT_EXCHANGE,
     HEADERS: {
       durable: true,
       deadLetterExchange: 'dlx',
-      deadLetterRoutingKey: 'physical_nft_deposit_dlq',
-      // arguments: { "x-single-active-consumer": true }, 순서보장용도
+      deadLetterRoutingKey: 'physical_nft_transfer_dlq',
     },
@@ -37,0 +54,0 @@ },

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

159765

increased by1.63%

Lines of code

1400

increased by5.03%

No dependency changes