Skip to content

Commit a2b5bb6

Browse files
Petr Matousekjiridanek
authored andcommitted
FIX(formatter) use dashes not underscores for message field keys
1 parent db80879 commit a2b5bb6

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

lib/formatter.js

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -203,13 +203,13 @@ class Formatter {
203203

204204
//amqp properties
205205
workDict['id'] = dict['message_id'];
206-
workDict['user_id'] = Formatter.castUserId(dict['user_id']);
206+
workDict['user-id'] = Formatter.castUserId(dict['user_id']);
207207
workDict['to'] = dict['to'];
208208
workDict['subject'] = dict['subject'];
209-
workDict['reply_to'] = dict['reply_to'];
210-
workDict['correlation_id'] = dict['correlation_id'];
211-
workDict['content_type'] = dict['content_type'];
212-
workDict['content_encoding'] = dict['content_encoding'];
209+
workDict['reply-to'] = dict['reply_to'];
210+
workDict['correlation-id'] = dict['correlation_id'];
211+
workDict['content-type'] = dict['content_type'];
212+
workDict['content-encoding'] = dict['content_encoding'];
213213
workDict['absolute-expiry-time'] = dict['absolute_expiry_time'];
214214
workDict['creation-time'] = dict['creation_time'].getTime();
215215
workDict['group-id'] = dict['group_id'];

0 commit comments

Comments
 (0)