File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed
projects/client/RabbitMQ.Client/src/client Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -636,7 +636,7 @@ void HandleBasicReturn(ushort replyCode,
636
636
///<summary>Used to send a Channel.FlowOk. Confirms that
637
637
///Channel.Flow from the broker was processed.</summary>
638
638
[ AmqpMethodMapping ( null , "channel" , "flow-ok" ) ]
639
- void _Private_ChannelFlowOk ( ) ;
639
+ void _Private_ChannelFlowOk ( bool active ) ;
640
640
641
641
///<summary>Handle incoming Channel.Flow methods. Either
642
642
///stops or resumes sending the methods that have content.</summary>
Original file line number Diff line number Diff line change @@ -146,8 +146,8 @@ public event CallbackExceptionEventHandler CallbackException
146
146
m_callbackException -= value ;
147
147
}
148
148
}
149
- }
150
-
149
+ }
150
+
151
151
public IBasicConsumer DefaultConsumer { get ; set ; }
152
152
153
153
public ISession m_session ;
@@ -402,15 +402,15 @@ public void HandleBasicReturn(ushort replyCode,
402
402
OnBasicReturn ( e ) ;
403
403
}
404
404
405
- public abstract void _Private_ChannelFlowOk ( ) ;
405
+ public abstract void _Private_ChannelFlowOk ( bool active ) ;
406
406
407
407
public void HandleChannelFlow ( bool active )
408
408
{
409
409
if ( active )
410
410
m_flowControlBlock . Set ( ) ;
411
411
else
412
412
m_flowControlBlock . Reset ( ) ;
413
- _Private_ChannelFlowOk ( ) ;
413
+ _Private_ChannelFlowOk ( active ) ;
414
414
}
415
415
416
416
public void HandleConnectionStart ( byte versionMajor ,
You can’t perform that action at this time.
0 commit comments