Refactor FullSubjectName method for compatibility (superstreamlabs#164)

tbazen · Dec 4, 2023 · 562ed44 · 562ed44
1 parent a68f0ea
commit 562ed44
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/src/Memphis.Client/Producer/MemphisProducer.cs b/src/Memphis.Client/Producer/MemphisProducer.cs
@@ -233,12 +233,14 @@ async Task ReInitializeProducerAndRetry(byte[] message, NameValueCollection head
 
         string FullSubjectName()
         {
-            string partitionString = streamName.Split('$')[1];
-            int partitionNumber = Convert.ToInt32(partitionString);
-            if (_memphisClient.FunctionDetails.TryGetValue(_internalStationName, out var functionDetails) &&
-                functionDetails.PartitionsFunctions.TryGetValue(partitionNumber, out var functionId))
+            if (_memphisClient.FunctionDetails.TryGetValue(_internalStationName, out var functionDetails))
             {
-                return $"{streamName}.functions.{functionId}";
+                string partitionString = streamName.Split('$')[1];
+                int partitionNumber = Convert.ToInt32(partitionString);
+                if (functionDetails.PartitionsFunctions.TryGetValue(partitionNumber, out var functionId))
+                {
+                    return $"{streamName}.functions.{functionId}";
+                }
             }
             return $"{streamName}.final";
         }