@@ -768,27 +768,6 @@ func TestClient(t *testing.T) {
768
768
"expected 'OP_MSG' OpCode in wire message, got %q" , pair .Sent .OpCode .String ())
769
769
}
770
770
})
771
-
772
- // Test that OP_MSG is used for handshakes when loadBalanced is true.
773
- opMsgLBOpts := mtest .NewOptions ().ClientType (mtest .Proxy ).MinServerVersion ("5.0" ).Topologies (mtest .LoadBalanced )
774
- mt .RunOpts ("OP_MSG used for handshakes when loadBalanced is true" , opMsgLBOpts , func (mt * mtest.T ) {
775
- err := mt .Client .Ping (context .Background (), mtest .PrimaryRp )
776
- assert .Nil (mt , err , "Ping error: %v" , err )
777
-
778
- msgPairs := mt .GetProxiedMessages ()
779
- assert .True (mt , len (msgPairs ) >= 3 , "expected at least 3 events, got %v" , len (msgPairs ))
780
-
781
- // First three messages should be connection handshakes: one for the heartbeat connection, another for the
782
- // application connection, and a final one for the RTT monitor connection.
783
- for idx , pair := range msgPairs [:3 ] {
784
- assert .Equal (mt , "hello" , pair .CommandName , "expected command name 'hello' at index %d, got %s" , idx ,
785
- pair .CommandName )
786
-
787
- // Assert that appended OpCode is OP_MSG when loadBalanced is true.
788
- assert .Equal (mt , wiremessage .OpMsg , pair .Sent .OpCode ,
789
- "expected 'OP_MSG' OpCode in wire message, got %q" , pair .Sent .OpCode .String ())
790
- }
791
- })
792
771
}
793
772
794
773
func TestClient_BSONOptions (t * testing.T ) {
0 commit comments