Sha256: 7cb4b54065e7ff263c6414338aa28c6ff4ac4087e592b9110db21df62d0af815
Contents?: true
Size: 1.95 KB
Versions: 10
Compression:
Stored size: 1.95 KB
Contents
# frozen_string_literal: true
require 'luna_park/errors/system'
require 'luna_park/errors/business'
module CycloneLariat
module Errors
class EmptyMessage < LunaPark::Errors::System
message 'Received message is empty'
end
class ClientError < LunaPark::Errors::Business
attr_writer :message, :details
def ==(other)
other.is_a?(LunaPark::Errors::Business) &&
other.message == message &&
other.details == details
end
end
class TopicAlreadyExists < LunaPark::Errors::System
message { |d| "Topic already exists: `#{d[:expected_topic]}`" }
end
class TopicDoesNotExists < LunaPark::Errors::System
message { |d| "Topic does not exists: `#{d[:expected_topic]}`" }
end
class QueueAlreadyExists < LunaPark::Errors::System
message { |d| "Queue already exists: `#{d[:expected_queue]}`" }
end
class QueueDoesNotExists < LunaPark::Errors::System
message { |d| "Queue does not exists: `#{d[:expected_queue]}`" }
end
class SubscriptionAlreadyExists < LunaPark::Errors::System
message { |d| "Subscription for topic `#{d[:topic].name}`, on endpoint `#{d[:endpoint].name}` already exists" }
end
class SubscriptionDoesNotExists < LunaPark::Errors::System
message { |d| "Subscription for topic `#{d[:topic].name}`, on endpoint `#{d[:endpoint].name}` does not exists" }
end
class InvalidMessage < LunaPark::Errors::Business
message 'Message is not valid'
end
class GroupIdUndefined < LunaPark::Errors::System
message { |d| "Group id must be defined for FIFO resources: `#{d[:resource].name}`" }
end
class GroupDefined < LunaPark::Errors::System
message { |d| "Group id must be nil for non-FIFO resources: `#{d[:resource].name}`" }
end
class DeduplicationIdDefined < LunaPark::Errors::System
message { |d| "Deduplication id must be nil for non-FIFO resources: `#{d[:resource].name}`" }
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems