File tree Expand file tree Collapse file tree 2 files changed +28
-0
lines changed
projects/client/RabbitMQ.Client/src/client Expand file tree Collapse file tree 2 files changed +28
-0
lines changed Original file line number Diff line number Diff line change @@ -1017,6 +1017,20 @@ void HandleConnectionClose(ushort replyCode,
1017
1017
string replyText ,
1018
1018
ushort classId ,
1019
1019
ushort methodId ) ;
1020
+
1021
+ ///<summary>Handle an incoming Connection.Blocked.</summary>
1022
+ [ AmqpMethodMapping ( null , "connection" , "blocked" ) ]
1023
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_8qpid" ) ]
1024
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_8" ) ]
1025
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_9" ) ]
1026
+ void HandleConnectionBlocked ( string reason ) ;
1027
+
1028
+ ///<summary>Handle an incominga Connection.Unblocked.</summary>
1029
+ [ AmqpMethodMapping ( null , "connection" , "unblocked" ) ]
1030
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_8qpid" ) ]
1031
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_8" ) ]
1032
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_9" ) ]
1033
+ void HandleConnectionUnblocked ( ) ;
1020
1034
}
1021
1035
1022
1036
///<summary>Essential information from an incoming Connection.Tune
Original file line number Diff line number Diff line change @@ -724,6 +724,20 @@ public void HandleConnectionClose(ushort replyCode,
724
724
}
725
725
}
726
726
727
+ public void HandleConnectionBlocked ( string reason )
728
+ {
729
+ ConnectionBase cb = ( ( ConnectionBase ) m_session . Connection ) ;
730
+
731
+ cb . HandleConnectionBlocked ( reason ) ;
732
+ }
733
+
734
+ public void HandleConnectionUnblocked ( )
735
+ {
736
+ ConnectionBase cb = ( ( ConnectionBase ) m_session . Connection ) ;
737
+
738
+ cb . HandleConnectionUnblocked ( ) ;
739
+ }
740
+
727
741
public void HandleChannelClose ( ushort replyCode ,
728
742
string replyText ,
729
743
ushort classId ,
You can’t perform that action at this time.
0 commit comments