fix(message-properties): added missing amqp symbols for two fields

noodlefrenzy · May 21, 2015 · d745d85 · d745d85
1 parent 1e38312
commit d745d85
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/lib/types/message.js b/lib/types/message.js
@@ -160,8 +160,8 @@ Properties.fromDescribedType = function(describedType) {
     to: propertiesArr[idx++],
     subject: propertiesArr[idx++],
     replyTo: propertiesArr[idx++],
-    correlationId: propertiesArr[idx++],
-    contentType: propertiesArr[idx++],
+    correlationId: propertiesArr[idx++].contents,     // AMQPSymbol
+    contentType: propertiesArr[idx++].contents,       // AMQPSymbol
     contentEncoding: propertiesArr[idx++],
     absoluteExpiryTime: propertiesArr[idx++],
     creationTime: propertiesArr[idx++],
@@ -181,8 +181,8 @@ Properties.prototype.getValue = function() {
     subject: u.orNull(self.subject),
     replyTo: u.orNull(self.replyTo),
     correlationId: u.orNull(self.correlationId),
-    contentType: u.orNull(self.contentType),
-    contentEncoding: u.orNull(self.contentEncoding),
+    contentType: (self.contentType === undefined) ? null : new AMQPSymbol(self.contentType),
+    contentEncoding: (self.contentEncoding === undefined) ? null : new AMQPSymbol(self.contentEncoding),
     absoluteExpiryTime: (self.absoluteExpiryTime === undefined) ? null : new ForcedType('timestamp', self.absoluteExpiryTime),
     creationTime: (self.creationTime === undefined) ? null : new ForcedType('timestamp', self.creationTime),
     groupId: u.orNull(self.groupId),