@@ -167,18 +167,18 @@ protected override async Task EnsureTopicCreatedAsync(CancellationToken cancella
167167
168168 // Create the client connection, channel, declares the exchange, queue and binds
169169 // the exchange with the publisher queue. It requires the name of our exchange, exchange type, durability and auto-delete.
170- // For now, we are using same autoDelete for both exchange and queue ( it will survive a server restart )
170+ // For now, we are using same autoDelete for both exchange and queue (it will survive a server restart)
171171 _publisherConnection = await CreateConnectionAsync ( ) . AnyContext ( ) ;
172172 _publisherChannel = await _publisherConnection . CreateChannelAsync ( cancellationToken : cancellationToken ) . AnyContext ( ) ;
173173
174174 // We first attempt to create "x-delayed-type". For this plugin should be installed.
175175 // However, we plug in is not installed this will throw an exception. In that case
176176 // we attempt to create regular exchange. If regular exchange also throws and exception
177- // then trouble shoot the problem.
177+ // then troubleshoot the problem.
178178 if ( ! await CreateDelayedExchangeAsync ( _publisherChannel ) . AnyContext ( ) )
179179 {
180- // if the initial exchange creation was not successful then we must close the previous connection
181- // and establish the new client connection and model otherwise you will keep receiving failure in creation
180+ // if the initial exchange creation was not successful, then we must close the previous connection
181+ // and establish the new client connection and model; otherwise you will keep receiving failure in creation
182182 // of the regular exchange too.
183183 await _publisherChannel . DisposeAsync ( ) . AnyContext ( ) ;
184184 await _publisherConnection . DisposeAsync ( ) . AnyContext ( ) ;
0 commit comments