@@ -702,10 +702,25 @@ namespace RabbitMQ.Client.Exceptions
702
702
public ChannelAllocationException(int channel) { }
703
703
public int Channel { get; }
704
704
}
705
+ public class ChannelErrorException : RabbitMQ.Client.Exceptions.HardProtocolException
706
+ {
707
+ public ChannelErrorException(int channel) { }
708
+ public int Channel { get; }
709
+ public override ushort ReplyCode { get; }
710
+ }
705
711
public class ConnectFailureException : RabbitMQ.Client.ProtocolViolationException
706
712
{
707
713
public ConnectFailureException(string msg, System.Exception inner) { }
708
714
}
715
+ public abstract class HardProtocolException : RabbitMQ.Client.Exceptions.ProtocolException
716
+ {
717
+ protected HardProtocolException(string message) { }
718
+ }
719
+ public class MalformedFrameException : RabbitMQ.Client.Exceptions.HardProtocolException
720
+ {
721
+ public MalformedFrameException(string message) { }
722
+ public override ushort ReplyCode { get; }
723
+ }
709
724
public class OperationInterruptedException : RabbitMQ.Client.Exceptions.RabbitMQClientException
710
725
{
711
726
protected OperationInterruptedException() { }
@@ -728,6 +743,12 @@ namespace RabbitMQ.Client.Exceptions
728
743
public PossibleAuthenticationFailureException(string msg) { }
729
744
public PossibleAuthenticationFailureException(string msg, System.Exception inner) { }
730
745
}
746
+ public abstract class ProtocolException : RabbitMQ.Client.Exceptions.RabbitMQClientException
747
+ {
748
+ protected ProtocolException(string message) { }
749
+ public abstract ushort ReplyCode { get; }
750
+ public virtual RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; }
751
+ }
731
752
public class ProtocolVersionMismatchException : RabbitMQ.Client.ProtocolViolationException
732
753
{
733
754
public ProtocolVersionMismatchException(int clientMajor, int clientMinor, int serverMajor, int serverMinor) { }
@@ -742,11 +763,33 @@ namespace RabbitMQ.Client.Exceptions
742
763
protected RabbitMQClientException(string message) { }
743
764
protected RabbitMQClientException(string message, System.Exception innerException) { }
744
765
}
766
+ public abstract class SoftProtocolException : RabbitMQ.Client.Exceptions.ProtocolException
767
+ {
768
+ protected SoftProtocolException(int channelNumber, string message) { }
769
+ public int Channel { get; }
770
+ }
771
+ public class SyntaxErrorException : RabbitMQ.Client.Exceptions.HardProtocolException
772
+ {
773
+ public SyntaxErrorException(string message) { }
774
+ public override ushort ReplyCode { get; }
775
+ }
776
+ public class UnexpectedFrameException : RabbitMQ.Client.Exceptions.HardProtocolException
777
+ {
778
+ public override ushort ReplyCode { get; }
779
+ }
745
780
public class UnexpectedMethodException : RabbitMQ.Client.ProtocolViolationException
746
781
{
747
782
public UnexpectedMethodException(RabbitMQ.Client.IMethod method) { }
748
783
public RabbitMQ.Client.IMethod Method { get; }
749
784
}
785
+ public class UnknownClassOrMethodException : RabbitMQ.Client.Exceptions.HardProtocolException
786
+ {
787
+ public UnknownClassOrMethodException(ushort classId, ushort methodId) { }
788
+ public ushort ClassId { get; }
789
+ public ushort MethodId { get; }
790
+ public override ushort ReplyCode { get; }
791
+ public override string ToString() { }
792
+ }
750
793
public class UnsupportedMethodException : System.NotSupportedException
751
794
{
752
795
public UnsupportedMethodException(string methodName) { }
@@ -765,52 +808,6 @@ namespace RabbitMQ.Client.Exceptions
765
808
public object Offender { get; }
766
809
}
767
810
}
768
- namespace RabbitMQ.Client.Impl
769
- {
770
- public class ChannelErrorException : RabbitMQ.Client.Impl.HardProtocolException
771
- {
772
- public ChannelErrorException(int channel) { }
773
- public int Channel { get; }
774
- public override ushort ReplyCode { get; }
775
- }
776
- public abstract class HardProtocolException : RabbitMQ.Client.Impl.ProtocolException
777
- {
778
- protected HardProtocolException(string message) { }
779
- }
780
- public class MalformedFrameException : RabbitMQ.Client.Impl.HardProtocolException
781
- {
782
- public MalformedFrameException(string message) { }
783
- public override ushort ReplyCode { get; }
784
- }
785
- public abstract class ProtocolException : RabbitMQ.Client.Exceptions.RabbitMQClientException
786
- {
787
- protected ProtocolException(string message) { }
788
- public abstract ushort ReplyCode { get; }
789
- public virtual RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; }
790
- }
791
- public abstract class SoftProtocolException : RabbitMQ.Client.Impl.ProtocolException
792
- {
793
- protected SoftProtocolException(int channelNumber, string message) { }
794
- public int Channel { get; }
795
- }
796
- public class SyntaxError : RabbitMQ.Client.Impl.HardProtocolException
797
- {
798
- public SyntaxError(string message) { }
799
- public override ushort ReplyCode { get; }
800
- }
801
- public class UnexpectedFrameException : RabbitMQ.Client.Impl.HardProtocolException
802
- {
803
- public override ushort ReplyCode { get; }
804
- }
805
- public class UnknownClassOrMethodException : RabbitMQ.Client.Impl.HardProtocolException
806
- {
807
- public UnknownClassOrMethodException(ushort classId, ushort methodId) { }
808
- public ushort ClassId { get; }
809
- public ushort MethodId { get; }
810
- public override ushort ReplyCode { get; }
811
- public override string ToString() { }
812
- }
813
- }
814
811
namespace RabbitMQ.Client.Logging
815
812
{
816
813
[System.Diagnostics.Tracing.EventSource(Name="rabbitmq-dotnet-client")]
0 commit comments