enum Crabbit::ResponseCode

Overview

RabbitMQ Stream protocol response status.

Ok is the sole success value. Other values can be inspected on BrokerError#code or converted to an exception with #raise_unless_ok!.

Defined in:

crabbit/response_code.cr

Enum Members

Ok = 1_u16
StreamDoesNotExist = 2_u16
SubscriptionIdAlreadyExists = 3_u16
SubscriptionIdDoesNotExist = 4_u16
StreamAlreadyExists = 5_u16
StreamNotAvailable = 6_u16
SaslMechanismNotSupported = 7_u16
AuthenticationFailure = 8_u16
SaslError = 9_u16
SaslChallenge = 10_u16
AuthenticationFailureLoopback = 11_u16
VirtualHostAccessFailure = 12_u16
UnknownFrame = 13_u16
FrameTooLarge = 14_u16
InternalError = 15_u16
AccessRefused = 16_u16
PreconditionFailed = 17_u16
PublisherDoesNotExist = 18_u16
NoOffset = 19_u16
SaslCannotChangeMechanism = 20_u16
SaslCannotChangeUsername = 21_u16

Instance Method Summary

Instance Method Detail

def access_refused? #

Returns true if this enum value equals AccessRefused


[View source]
def authentication_failure? #

Returns true if this enum value equals AuthenticationFailure


[View source]
def authentication_failure_loopback? #

Returns true if this enum value equals AuthenticationFailureLoopback


[View source]
def frame_too_large? #

Returns true if this enum value equals FrameTooLarge


[View source]
def internal_error? #

Returns true if this enum value equals InternalError


[View source]
def no_offset? #

Returns true if this enum value equals NoOffset


[View source]
def ok? : Bool #

Returns whether this code represents success.


[View source]
def precondition_failed? #

Returns true if this enum value equals PreconditionFailed


[View source]
def publisher_does_not_exist? #

Returns true if this enum value equals PublisherDoesNotExist


[View source]
def raise_unless_ok!(context : String | Nil = nil) : Nil #

Raises BrokerError unless this code is Ok.

Optional context is prepended to the generated error message.


[View source]
def sasl_cannot_change_mechanism? #

Returns true if this enum value equals SaslCannotChangeMechanism


[View source]
def sasl_cannot_change_username? #

Returns true if this enum value equals SaslCannotChangeUsername


[View source]
def sasl_challenge? #

Returns true if this enum value equals SaslChallenge


[View source]
def sasl_error? #

Returns true if this enum value equals SaslError


[View source]
def sasl_mechanism_not_supported? #

Returns true if this enum value equals SaslMechanismNotSupported


[View source]
def stream_already_exists? #

Returns true if this enum value equals StreamAlreadyExists


[View source]
def stream_does_not_exist? #

Returns true if this enum value equals StreamDoesNotExist


[View source]
def stream_not_available? #

Returns true if this enum value equals StreamNotAvailable


[View source]
def subscription_id_already_exists? #

Returns true if this enum value equals SubscriptionIdAlreadyExists


[View source]
def subscription_id_does_not_exist? #

Returns true if this enum value equals SubscriptionIdDoesNotExist


[View source]
def unknown_frame? #

Returns true if this enum value equals UnknownFrame


[View source]
def virtual_host_access_failure? #

Returns true if this enum value equals VirtualHostAccessFailure


[View source]