diff --git a/.env.default b/.env.default index f27a152..409bb67 100644 --- a/.env.default +++ b/.env.default @@ -2,8 +2,8 @@ RABBITMQ_HOST=localhost RABBITMQ_USER=alkemio-admin RABBITMQ_PASSWORD=alkemio! RABBITMQ_PORT=5672 -RABBITMQ_INGEST_SPACE_QUEUE=virtual-contributor-ingest-space -RABBITMQ_INGEST_SPACE_RESULT_QUEUE=virtual-contributor-ingest-space-result +RABBITMQ_INGEST_BODY_OF_KNOWLEDGE_QUEUE=virtual-contributor-ingest-body-of-knowledge +RABBITMQ_INGEST_BODY_OF_KNOWLEDGE_RESULT_QUEUE=virtual-contributor-ingest-body-of-knowledge-result RABBITMQ_EVENT_BUS_EXCHANGE=event-bus API_ENDPOINT_PRIVATE_GRAPHQL='http://localhost:3000/api/private/non-interactive/graphql' diff --git a/package-lock.json b/package-lock.json index 656198b..0f3a1f5 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "@alkemio/ingest-alkemio-data", - "version": "0.11.0", + "version": "0.11.1", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@alkemio/ingest-alkemio-data", - "version": "0.11.0", + "version": "0.11.1", "license": "EUPL-1.2", "dependencies": { "@alkemio/client-lib": "^0.31.0", diff --git a/package.json b/package.json index feb3b7e..0dc575c 100755 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@alkemio/ingest-alkemio-data", - "version": "0.11.0", + "version": "0.11.1", "description": "", "author": "Alkemio Foundation", "private": true, diff --git a/src/event.bus/connection.ts b/src/event.bus/connection.ts index 1aee959..0a7fe12 100644 --- a/src/event.bus/connection.ts +++ b/src/event.bus/connection.ts @@ -47,8 +47,12 @@ export class Connection { user: this.getEnvValue('RABBITMQ_USER'), password: this.getEnvValue('RABBITMQ_PASSWORD'), port: this.getEnvValue('RABBITMQ_PORT'), - incomingQueue: this.getEnvValue('RABBITMQ_INGEST_SPACE_QUEUE'), - outgoingQueue: this.getEnvValue('RABBITMQ_INGEST_SPACE_RESULT_QUEUE'), + incomingQueue: this.getEnvValue( + 'RABBITMQ_INGEST_BODY_OF_KNOWLEDGE_QUEUE' + ), + outgoingQueue: this.getEnvValue( + 'RABBITMQ_INGEST_BODY_OF_KNOWLEDGE_RESULT_QUEUE' + ), exchange: this.getEnvValue('RABBITMQ_EVENT_BUS_EXCHANGE'), }; }