File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
RabbitMQ.AMQP.Client/Impl Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -79,9 +79,11 @@ public IConsumerBuilder ConsumerBuilder()
79
79
return new AmqpConsumerBuilder ( this ) ;
80
80
}
81
81
82
+ // TODO cancellation token
82
83
public override async Task OpenAsync ( )
83
84
{
84
- await OpenConnectionAsync ( )
85
+ // TODO cancellation token
86
+ await OpenConnectionAsync ( CancellationToken . None )
85
87
. ConfigureAwait ( false ) ;
86
88
await base . OpenAsync ( )
87
89
. ConfigureAwait ( false ) ;
@@ -198,8 +200,7 @@ private AmqpConnection(IConnectionSettings connectionSettings)
198
200
new AmqpManagement ( new AmqpManagementParameters ( this ) . TopologyListener ( _recordingTopologyListener ) ) ;
199
201
}
200
202
201
- // TODO cancellation token
202
- private async Task OpenConnectionAsync ( )
203
+ private async Task OpenConnectionAsync ( CancellationToken cancellationToken )
203
204
{
204
205
await _semaphoreOpen . WaitAsync ( )
205
206
. ConfigureAwait ( false ) ;
@@ -396,7 +397,8 @@ void DoClose(Error? argError = null)
396
397
await Task . Delay ( TimeSpan . FromMilliseconds ( nextDelayMs ) )
397
398
. ConfigureAwait ( false ) ;
398
399
399
- await OpenConnectionAsync ( )
400
+ // TODO cancellation token
401
+ await OpenConnectionAsync ( CancellationToken . None )
400
402
. ConfigureAwait ( false ) ;
401
403
402
404
connected = true ;
You can’t perform that action at this time.
0 commit comments