Skip to content

Commit 89f29d1

Browse files
connection.* methods should not ignore AlreadyClosedException
The change got lost earlier during branch re-creation.
1 parent c7c3957 commit 89f29d1

File tree

1 file changed

+3
-23
lines changed

1 file changed

+3
-23
lines changed

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

Lines changed: 3 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -1397,15 +1397,8 @@ public ConnectionSecureOrTune ConnectionStartOk(IDictionary<string, object> clie
13971397
{
13981398
ConnectionStartRpcContinuation k = new ConnectionStartRpcContinuation();
13991399
Enqueue(k);
1400-
try
1401-
{
1402-
_Private_ConnectionStartOk(clientProperties, mechanism,
1400+
_Private_ConnectionStartOk(clientProperties, mechanism,
14031401
response, locale);
1404-
}
1405-
catch (AlreadyClosedException)
1406-
{
1407-
// Ignored, see BasicGet
1408-
}
14091402
k.GetReply();
14101403
return k.m_result;
14111404
}
@@ -1427,14 +1420,7 @@ public ConnectionSecureOrTune ConnectionSecureOk(byte[] response)
14271420
{
14281421
ConnectionStartRpcContinuation k = new ConnectionStartRpcContinuation();
14291422
Enqueue(k);
1430-
try
1431-
{
1432-
_Private_ConnectionSecureOk(response);
1433-
}
1434-
catch (AlreadyClosedException)
1435-
{
1436-
// Ignored, see BasicGet
1437-
}
1423+
_Private_ConnectionSecureOk(response);
14381424
k.GetReply();
14391425
return k.m_result;
14401426
}
@@ -1473,13 +1459,7 @@ public string ConnectionOpen(string virtualHost,
14731459
{
14741460
ConnectionOpenContinuation k = new ConnectionOpenContinuation();
14751461
Enqueue(k);
1476-
try {
1477-
_Private_ConnectionOpen(virtualHost, capabilities, insist);
1478-
}
1479-
catch (AlreadyClosedException)
1480-
{
1481-
// Ignored, see BasicGet
1482-
}
1462+
_Private_ConnectionOpen(virtualHost, capabilities, insist);
14831463
k.GetReply();
14841464
if (k.m_redirect) {
14851465
throw new RedirectException(m_session.Connection.Protocol,

0 commit comments

Comments
 (0)