diff --git a/src/domain/models/Message.ts b/src/domain/models/Message.ts
index 8a7af3edf..8671f7aef 100644
--- a/src/domain/models/Message.ts
+++ b/src/domain/models/Message.ts
@@ -36,10 +36,10 @@ export class Message implements Pluto.Storable {
       1 * 24 * 60 * 60
     ).toString(),
     public readonly ack: string[] = [],
-    public readonly direction: MessageDirection = MessageDirection.RECEIVED,
+    public direction: MessageDirection = MessageDirection.RECEIVED,
     public readonly fromPrior?: string,
     public readonly pthid?: string
-  ) {}
+  ) { }
 
   static fromJson(jsonString: JsonString): Message {
     const messageObj = JSON.parse(jsonString);
diff --git a/src/prism-agent/connectionsManager/ConnectionsManager.ts b/src/prism-agent/connectionsManager/ConnectionsManager.ts
index 4bb70e93e..b2f3b9c58 100644
--- a/src/prism-agent/connectionsManager/ConnectionsManager.ts
+++ b/src/prism-agent/connectionsManager/ConnectionsManager.ts
@@ -247,6 +247,7 @@ export class ConnectionsManager implements ConnectionsManagerClass {
    * @returns {Promise<Message | undefined>}
    */
   async sendMessage(message: Message): Promise<Message | undefined> {
+    message.direction = MessageDirection.SENT;
     await this.pluto.storeMessage(message);
     return this.mercury.sendMessageParseMessage(message);
   }