File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -94,8 +94,8 @@ public async Task CloseConnectionAsync(string connectionClientProvidedName)
94
94
95
95
if ( connectionToClose == null )
96
96
{
97
- _output . WriteLine ( "{0} [WARNING] could not find/delete connection: '{1}'" ,
98
- Now , connectionClientProvidedName ) ;
97
+ throw new InvalidOperationException (
98
+ $ " { Now } [ERROR] could not find/delete connection: ' { connectionClientProvidedName } '" ) ;
99
99
}
100
100
}
101
101
Original file line number Diff line number Diff line change @@ -187,7 +187,9 @@ public async Task TestTopologyRecoveryBindingFilter()
187
187
188
188
AutorecoveringConnection conn = await CreateAutorecoveringConnectionWithTopologyRecoveryFilterAsync ( filter ) ;
189
189
conn . RecoverySucceeded += ( source , ea ) => tcs . SetResult ( true ) ;
190
+
190
191
IChannel ch = await conn . CreateChannelAsync ( ) ;
192
+
191
193
try
192
194
{
193
195
string exchange = "topology.recovery.exchange" ;
You can’t perform that action at this time.
0 commit comments