feat(message): expose isSealed as public field

CheerlessCloud · Sep 24, 2018 · 32729ae · 32729ae
1 parent 5b90b53
commit 32729ae
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/AMQPMessage.js b/src/AMQPMessage.js
@@ -10,6 +10,7 @@ export interface IMessage {
   +id: ?string;
   +correlationId: ?string;
   +payload: Object;
+  +isSealed: boolean;
   +headers: Map<string, mixed>;
   +isAnswerQueueEnabled: boolean;
   +_props: MessageProps;
@@ -27,9 +28,10 @@ export default class AMQPMessage implements IMessage {
   _amqpMessage: CommonAMQPMessage;
   _isSealed: boolean = false;
 
-  constructor(amqpMessage: CommonAMQPMessage, channel: AMQPChannel): IMessage {
+  constructor(amqpMessage: CommonAMQPMessage, channel: AMQPChannel, isSealed: ?boolean): IMessage {
     this._channel = channel;
     this._amqpMessage = amqpMessage;
+    this._isSealed = isSealed || false;
     return this;
   }
 
@@ -45,6 +47,10 @@ export default class AMQPMessage implements IMessage {
     return this.getPayloadAsObject();
   }
 
+  get isSealed(): boolean {
+    return this._isSealed;
+  }
+
   get _props(): MessageProps {
     return { ...this._amqpMessage.properties, ...this._amqpMessage.fields };
   }