diff --git a/index.js b/index.js
index 42de98f..1e606b8 100644
--- a/index.js
+++ b/index.js
@@ -11,7 +11,7 @@ function sleep(ms) {
 }
 
 const CLIENT_INFO_HEADER_KEY = "Client-Information";
-const CLIENT_INFO_HEADER_VALUE = "IntrinioRealtimeNodeSDKv5.2";
+const CLIENT_INFO_HEADER_VALUE = "IntrinioRealtimeNodeSDKv5.3";
 const MESSAGE_VERSION_HEADER_KEY = "UseNewEquitiesFormat";
 const MESSAGE_VERSION_HEADER_VALUE = "v2";
 const EVENT_BUFFER_SIZE = 100;
@@ -417,6 +417,8 @@ class IntrinioRealtime {
   _parseTrade(bytes) {
     let symbolLength = bytes[2];
     let conditionLength = bytes[26 + symbolLength];
+    let marketCenter = readUnicodeString(bytes, 4 + symbolLength, 6 + symbolLength);
+    let isDarkpool = (!marketCenter) || marketCenter == "\0" || marketCenter == "D" || marketCenter == "E" || marketCenter.trim().length === 0;
     return {
       Type: this._getMessageType(bytes[0]),
       Symbol: readString(bytes, 3, 3 + symbolLength),
@@ -425,8 +427,9 @@ class IntrinioRealtime {
       Timestamp: readUInt64(bytes, 14 + symbolLength),
       TotalVolume: readUInt32(bytes, 22 + symbolLength),
       SubProvider: this._getSubProvider(bytes[3 + symbolLength]),
-      MarketCenter: readUnicodeString(bytes, 4 + symbolLength, 6 + symbolLength),
-      Condition: conditionLength > 0 ? readString(bytes, 27 + symbolLength, 27 + symbolLength + conditionLength) : ""
+      MarketCenter: marketCenter,
+      Condition: conditionLength > 0 ? readString(bytes, 27 + symbolLength, 27 + symbolLength + conditionLength) : "",
+      IsDarkpool: isDarkpool
     }
   }
 
diff --git a/package.json b/package.json
index 164d38f..7cdf4a0 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "intrinio-realtime",
-  "version": "5.2.0",
+  "version": "5.3.0",
   "engines": {
     "node": ">=20.7.0"
   },
diff --git a/realtime.js b/realtime.js
index 303e362..cbeb80d 100644
--- a/realtime.js
+++ b/realtime.js
@@ -54,7 +54,7 @@ function onQuote(quote) {
 }
 
 let client = new Client(accessKey, onTrade, onQuote, config);
-await client.join("AAPL", false); //use $lobby for firehose.
+client.join("AAPL", false); //use $lobby for firehose.
 //require("./index").replayToCsv("outputFilePath.csv", config, ["$lobby"], false, accessKey)
 
 setInterval(() => {