Skip to content

Commit

Permalink
Merge branch 'release/2.0.0'
Browse files Browse the repository at this point in the history
  • Loading branch information
getvega committed May 31, 2017
2 parents 9c7a164 + f1ab414 commit 2f1b99b
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
@@ -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",
Expand Down
5 changes: 2 additions & 3 deletions src/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -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
});
Expand All @@ -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
Expand Down Expand Up @@ -480,7 +480,6 @@ function Carotte(config) {
config.transport.info(`${rpc ? '◀ ' : '◁ '} ${qualifier}`, {
context,
headers,
data,
response,
subscriber: qualifier,
destination: '',
Expand Down

0 comments on commit 2f1b99b

Please sign in to comment.