fix(subscriber): user current channel only for message management

ygrishajev · Jul 21, 2020 · f85da35 · f85da35
1 parent d8f1e06
commit f85da35
Show file tree

Hide file tree

Showing 8 changed files with 281 additions and 222 deletions.
diff --git a/Dockerfile b/Dockerfile
@@ -1,4 +1,4 @@
-FROM node:10-alpine
+FROM node:10
 
 RUN mkdir -p /usr/src/app
 WORKDIR /usr/src/app
@@ -13,3 +13,4 @@ COPY ./src ./src
 ARG YG_NPM_TOKEN
 
 RUN npm install
+RUN npm install jest -g
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -19,8 +19,9 @@ services:
       - docker-compose.env
     environment:
       YG_NPM_TOKEN: ${YG_NPM_TOKEN}
+      AMQP_URI: amqp://guest:guest@rabbitmq
   rabbitmq:
-    image: registry.gitlab.com/trysimply/cloud/rabbitmq-test
+    image: ygrishajev/rabbitmq-dev
     restart: on-failure
     ports:
       - "5672:5672"

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "rxamqp",
-  "version": "0.3.4",
+  "version": "0.3.5",
   "description": "Library for easy amqplib configuration and usage",
   "main": "./src/index.js",
   "scripts": {
@@ -36,6 +36,7 @@
     "lodash.flow": "^3.5.0",
     "rxjs": "^6.2.1",
     "rxjs-compat": "^6.2.1",
+    "util.promisify": "^1.0.1",
     "uuid": "^3.0.1"
   },
   "devDependencies": {