Skip to content

Commit

Permalink
fix non-correct WARN log about potentially failing connections status
Browse files Browse the repository at this point in the history
* the logic was assuming that 1 Publisher actor will only be started if targets are available which is a wrong assumption - it is always started

Signed-off-by: Thomas Jäckle <thomas.jaeckle@beyonnex.io>
  • Loading branch information
thjaeckle committed Jul 5, 2023
1 parent 2a45e29 commit b833d7d
Showing 1 changed file with 2 additions and 2 deletions.
Expand Up @@ -1443,8 +1443,8 @@ private FSM.State<BaseClientState, BaseClientData> retrieveConnectionStatus(fina
" Forwarding to consumers and publishers.", command.getEntityId(),
sender);

// only one PublisherActor is started for all targets (if targets are present)
final int numberOfProducers = connection.getTargets().isEmpty() ? 0 : 1;
// only one PublisherActor is started for all targets - and it always is started
final int numberOfProducers = 1;
final int numberOfConsumers = determineNumberOfConsumers();
int expectedNumberOfChildren = numberOfProducers + numberOfConsumers;
if (getSshTunnelState().isEnabled()) {
Expand Down

0 comments on commit b833d7d

Please sign in to comment.