Sha256: db577bcec9d3866e84e9191cd1801bb9ec2d9e540dc345c4bac9187e628331a4

Contents?: true

Size: 1.13 KB

Versions: 54

Compression:

Stored size: 1.13 KB

Contents

# frozen_string_literal: true

# :reek:IrresponsibleModule

module RubyRabbitmqJanus
  module Errors
    module Rabbit
      module Publisher
        # Define a super class for all errors in Rabbit::BaseEvent
        class BaseErrorPublisher < BaseRabbit
          def initialize(message, level = :fatal)
            super "[Publisher] #{message}", level
          end
        end

        module Base
          # Error for Rabbit::BaseEvent#initialize
          class Initialize < RubyRabbitmqJanus::Errors::Rabbit::Publisher::BaseErrorPublisher
            def initialize
              super 'Error in initializer'
            end
          end

          class Publish < RubyRabbitmqJanus::Errors::Rabbit::Publisher::BaseErrorPublisher
            def initialize
              super 'Error for publishing message'
            end
          end

          class TestCorrelation < RubyRabbitmqJanus::Errors::Rabbit::Publisher::BaseErrorPublisher
            def initialize(message, propertie)
              super "Correlation doesn't equal (msg: #{message}) != (prp: #{propertie})"
            end
          end
        end
      end
    end
  end
end

Version data entries

54 entries across 54 versions & 1 rubygems

Version Path
ruby_rabbitmq_janus-2.7.1.pre.274 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.7.0.pre.272 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.7.0 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.7.0.pre.269 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.7.0.pre.267 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.263 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.261 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.260 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.259 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.258 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.247 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.246 lib/rrj/errors/rabbit/publisher/base.rb
ruby_rabbitmq_janus-2.6.0.pre.244 lib/rrj/errors/rabbit/publisher/base.rb