@@ -729,11 +729,11 @@ private int AwaitReplayResponse()
729729 int errorCode = ( int ) _replayRequest . RelevantId ;
730730
731731 PersistentSubscriptionException . Reason reason ;
732- if ( errorCode == ArchiveException . INVALID_POSITION )
732+ if ( ArchiveException . INVALID_POSITION == errorCode )
733733 {
734734 reason = PersistentSubscriptionException . Reason . INVALID_START_POSITION ;
735735 }
736- else if ( errorCode == ArchiveException . UNKNOWN_RECORDING )
736+ else if ( ArchiveException . UNKNOWN_RECORDING == errorCode )
737737 {
738738 reason = PersistentSubscriptionException . Reason . RECORDING_NOT_FOUND ;
739739 }
@@ -1128,10 +1128,11 @@ private void SetLiveImageDeadline()
11281128 private void OnLiveImageDeadlineBreached ( )
11291129 {
11301130 _liveImageDeadlineBreached = true ;
1131- _listener . OnError ( new AeronEvent ( "No image became available on the live subscription within " +
1132- SystemUtil . FormatDuration ( _messageTimeoutNs ) + ". This could be " +
1133- "caused by the publisher being down, or by a misconfiguration of the " +
1134- "subscriber or a firewall between them." ) ) ;
1131+ _listener . OnError ( new AeronEvent (
1132+ "No image became available on the live subscription within " +
1133+ SystemUtil . FormatDuration ( _messageTimeoutNs ) + ". This could be " +
1134+ "caused by the publisher being down, or by a misconfiguration of the " +
1135+ "subscriber or a firewall between them." ) ) ;
11351136 }
11361137
11371138 private int AttemptSwitch ( int fragmentLimit , bool isControlled )
0 commit comments