fix sending username in creating and removing producer consumer

superstreamlabs · Jul 18, 2023 · 71aacfc · 71aacfc
1 parent 6b1d5f3
commit 71aacfc
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Memphis.Client/MemphisClient.cs b/src/Memphis.Client/MemphisClient.cs
@@ -64,6 +64,11 @@ public MemphisClient(Options brokerConnOptions, IConnection brokerConnection,
  _jetStreamContext = jetStreamContext ?? throw new ArgumentNullException(nameof(jetStreamContext));
  _connectionId = connectionId ?? throw new ArgumentNullException(nameof(connectionId));
  _userName = brokerConnOptions.User;
+ int usernameSeparatorIndex = _userName.LastIndexOf('$');
+ if (usernameSeparatorIndex >= 0)
+ {
+ _userName = _userName.Substring(0, usernameSeparatorIndex);
+ }
 
  _cancellationTokenSource = new();