Skip to content

Commit bc363f6

Browse files
author
Vikas Agarwal
committed
Trying without rabbitmq
1 parent 7f8af80 commit bc363f6

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/routes/projects/create.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -149,10 +149,10 @@ module.exports = [
149149
// add an empty attachments array
150150
newProject.attachments = [];
151151
req.log.debug('Sending event to RabbitMQ bus for project %d', newProject.id);
152-
req.app.services.pubsub.publish(EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED,
153-
newProject,
154-
{ correlationId: req.id },
155-
);
152+
// req.app.services.pubsub.publish(EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED,
153+
// newProject,
154+
// { correlationId: req.id },
155+
// );
156156
req.log.debug('Sending event to Kafka bus for project %d', newProject.id);
157157
// emit event
158158
req.app.emit(EVENT.ROUTING_KEY.PROJECT_DRAFT_CREATED, { req, project: newProject });

0 commit comments

Comments
 (0)