Skip to content

Commit de36d1f

Browse files
Remove redirect handling methods from model API
1 parent 350be31 commit de36d1f

File tree

2 files changed

+2
-24
lines changed

2 files changed

+2
-24
lines changed

projects/client/RabbitMQ.Client/src/client/api/IModel.cs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -942,13 +942,6 @@ void _Private_ConnectionOpen(string virtualHost,
942942
void HandleConnectionOpenOk([AmqpFieldMapping("RabbitMQ.Client.Framing.v0_9_1", "reserved1")]
943943
string knownHosts);
944944

945-
///<summary>Handle an incoming Connection.Redirect.
946-
/// (not available in AMQP 0-9-1)
947-
///</summary>
948-
[AmqpMethodDoNotImplement("RabbitMQ.Client.Framing.v0_9_1")]
949-
void HandleConnectionRedirect(string host,
950-
string knownHosts);
951-
952945
///<summary>Used to send a Connection.Close. Called during
953946
///connection shutdown.</summary>
954947
[AmqpMethodMapping(null, "connection", "close")]

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

Lines changed: 2 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -1493,13 +1493,8 @@ public string ConnectionOpen(string virtualHost,
14931493
// negotiation finishes
14941494
}
14951495
k.GetReply();
1496-
if (k.m_redirect) {
1497-
throw new RedirectException(m_session.Connection.Protocol,
1498-
k.m_host,
1499-
k.m_knownHosts);
1500-
} else {
1501-
return k.m_knownHosts;
1502-
}
1496+
1497+
return k.m_knownHosts;
15031498
}
15041499

15051500
public abstract void _Private_ConnectionOpen(string virtualHost,
@@ -1515,16 +1510,6 @@ public void HandleConnectionOpenOk(string knownHosts)
15151510
k.HandleCommand(null); // release the continuation.
15161511
}
15171512

1518-
public void HandleConnectionRedirect(string host,
1519-
string knownHosts)
1520-
{
1521-
ConnectionOpenContinuation k = (ConnectionOpenContinuation)m_continuationQueue.Next();
1522-
k.m_redirect = true;
1523-
k.m_host = host;
1524-
k.m_knownHosts = knownHosts;
1525-
k.HandleCommand(null); // release the continuation.
1526-
}
1527-
15281513
public abstract void _Private_ConnectionClose(ushort replyCode,
15291514
string replyText,
15301515
ushort classId,

0 commit comments

Comments
 (0)