File tree Expand file tree Collapse file tree 1 file changed +16
-0
lines changed Expand file tree Collapse file tree 1 file changed +16
-0
lines changed Original file line number Diff line number Diff line change @@ -165,6 +165,22 @@ public async Task InitializeAsync()
165
165
{
166
166
_connection = await _connectionFactory . CreateConnectionAsync ( _cancellationTokenSource . Token ) ;
167
167
168
+ _connection . ConnectionShutdown += ( sender , ea ) =>
169
+ {
170
+ _testOutputHelper . WriteLine ( "{0} [WARNING] connection shutdown!" , DateTime . Now ) ;
171
+ } ;
172
+
173
+ _connection . ConnectionRecoveryError += ( sender , ea ) =>
174
+ {
175
+ _testOutputHelper . WriteLine ( "{0} [ERROR] connection recovery error: {1}" ,
176
+ DateTime . Now , ea . Exception ) ;
177
+ } ;
178
+
179
+ _connection . RecoverySucceeded += ( sender , ea ) =>
180
+ {
181
+ _testOutputHelper . WriteLine ( "{0} [INFO] connection recovery succeeded" , DateTime . Now ) ;
182
+ } ;
183
+
168
184
_credentialsRefresher = new CredentialsRefresher ( _credentialsProvider ,
169
185
OnCredentialsRefreshedAsync ,
170
186
_cancellationTokenSource . Token ) ;
You can’t perform that action at this time.
0 commit comments