diff --git a/package.json b/package.json index 847b45b..daa24cd 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "carotte-amqp", - "version": "1.2.5", + "version": "2.0.0", "description": "AMQP wrapper for the carotte microservice framework", "main": "src/index.js", "repository": "https://github.com/cubyn/node-carotte-amqp", diff --git a/src/index.js b/src/index.js index 79949c6..dd25360 100644 --- a/src/index.js +++ b/src/index.js @@ -250,7 +250,7 @@ function Carotte(config) { config.transport.info(`${rpc ? '▶ ' : '▷ '} ${options.type}/${options.routingKey}`, { context: options.context, headers: options.headers, - data: payload, + request: payload, subscriber: options.context['origin-consumer'] || '', destination: qualifier }); @@ -272,7 +272,7 @@ function Carotte(config) { config.transport.error(`${rpc ? '▶ ' : '▷ '} ${options.type}/${options.routingKey}`, { context: options.context, headers: options.headers, - data: payload, + request: payload, subscriber: options.context['origin-consumer'] || '', destination: qualifier, error: err @@ -480,7 +480,6 @@ function Carotte(config) { config.transport.info(`${rpc ? '◀ ' : '◁ '} ${qualifier}`, { context, headers, - data, response, subscriber: qualifier, destination: '',