Sha256: 66a948e6c4c1023fea26d7b805243dfca49227a7bc9a2bef3f44c93dcec644b4
Contents?: true
Size: 1.16 KB
Versions: 6
Compression:
Stored size: 1.16 KB
Contents
# frozen_string_literal: true
module AMQP
class Client
class Error < StandardError; end
# Raised when a frame that wasn't expected arrives
class UnexpectedFrame < Error
def initialize(expected, actual)
super "Expected frame type '#{expected}' but got '#{actual}'"
end
end
# Raised when a frame doesn't end with 206
class UnexpectedFrameEnd < Error
def initialize(actual)
super "Expected frame end 206 but got '#{actual}'"
end
end
# Should never be raised as we support all offical frame types
class UnsupportedFrameType < Error
def initialize(type)
super "Unsupported frame type '#{type}'"
end
end
# Raised if a frame is received but not implemented
class UnsupportedMethodFrame < Error
def initialize(class_id, method_id)
super "Unsupported class/method: #{class_id} #{method_id}"
end
end
# Raised if channel is already closed
class ChannelClosedError < Error
def initialize(id, code, reason, classid = 0, methodid = 0)
super "Channel[#{id}] closed (#{code}) #{reason} (#{classid}/#{methodid})"
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems